Linux-ru

Код: Выделить всё

olej@nvme:~/Загрузки$ l -l Параллельное\ программирование\ на\ С++\ в\ действии.\ Практика\ разработки\ многопоточных\ программ.\ Энтони\ Уильямс 
-rw-rw-r-- 1 olej olej 2945342 мар  6 03:33 'Параллельное программирование на С++ в действии. Практика разработки многопоточных программ. Энтони Уильямс'

Код: Выделить всё

olej@nvme:~/Загрузки$ file Параллельное\ программирование\ на\ С++\ в\ действии.\ Практика\ разработки\ многопоточных\ программ.\ Энтони\ Уильямс 
Параллельное программирование на С++ в действии. Практика разработки многопоточных программ. Энтони Уильямс: PDF document, version 1.6

Код: Выделить всё

#include <iostream>
#include <atomic>         // std::atomic, std::atomic_flag, ATOMIC_FLAG_INIT
#include <thread>         // std::thread, std::this_thread::yield
#include <vector>         // std::vector
#include <unistd.h>

std::atomic<bool> ready (false);

class X
{
public:
	void do_lengthy_work( int tid, long int limit )
	{
		while (!ready) { std::this_thread::yield(); }  // wait for the ready signal
		do usleep( 1 );
		while (limit--);
		std::cout << "поток #" << tid << " завершился" << std::endl;
	};
};

int main ()
{
	std::vector<X> objs = { X(), X(), X(), X() };
	std::cout << "создание потоков, медленно считающих ..." << std::endl;
	std::vector<std::thread> threads;
	for (long unsigned int i = 0; i < objs.size(); ++i)
	{
		long int len = 10000 * (i + 1);
		threads.push_back(std::thread( &X::do_lengthy_work, &objs[ i ], i, len ) );
	}
	ready = true;
	for (auto& th : threads) th.join();
}

Код: Выделить всё

olej@nvme:~/2021/OWN_TEST.codes/asynch$ ./thread2
создание потоков, медленно считающих ...
поток #0 завершился
поток #1 завершился
поток #2 завершился
поток #3 завершился

Код: Выделить всё

#include <iostream>
#include <thread>

int main ()
{
	auto concurrent = std::thread(
		[]{
			std::this_thread::sleep_for(std::chrono::milliseconds(500)); // do something ...
			int sum = 0;
			for (int i = 0; i < 2000; ++i)
			sum += i;
			std::cout << "поток завершется..." << std::endl;
		}
	);
	std::cout << "поток запущен..." << std::endl;
	concurrent.join();
	std::cout << "программа завершется" << std::endl;
}

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ make
g++ -Wall -pthread -pedantic -std=c++14 -pthread thread_lambda.cc -o thread_lambda

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ ./thread_lambda 
поток запущен...
поток завершется...
программа завершется

Код: Выделить всё

#include <iostream>
#include <sstream>
#include <atomic>         // std::atomic, std::atomic_flag, ATOMIC_FLAG_INIT
#include <thread>         // std::thread, std::this_thread::yield

std::atomic<bool> ready(false);

int main ()
{
	const int num = 5;
	std::thread threads[ num ];
	for (int i = 0; i < num; ++i)
	{
		threads[i] = std::thread(
			[](int n){
				while (!ready) { std::this_thread::yield(); }                // wait for the ready signal
				std::this_thread::sleep_for(std::chrono::milliseconds(300)); // do something ...
				std::stringstream ss;
				ss << "поток " << n << " завершется..." << std::endl;
				std::cout << ss.str();
			}, i                                                                 // thread start parameters
		);
		std::cout << "поток " << i << " запущен..." << std::endl;
	}
	ready = true;                                                                        // simultaneous start of threads
	for (int i = 0; i < num; ++i)
		threads[i].join();
	std::cout << "программа завершется" << std::endl;
}

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ make
g++ -Wall -pthread -pedantic -std=c++14 -pthread thread_lambda_m.cc -o thread_lambda_m

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ ./thread_lambda_m 
поток 0 запущен...
поток 1 запущен...
поток 2 запущен...
поток 3 запущен...
поток 4 запущен...
поток 3 завершется...
поток 2 завершется...
поток 0 завершется...
поток 1 завершется...
поток 4 завершется...
программа завершется

Код: Выделить всё

#include <iostream>
#include <sstream>
#include <atomic>         // std::atomic, std::atomic_flag, ATOMIC_FLAG_INIT
#include <thread>         // std::thread, std::this_thread::yield
#include <chrono>
#include <random>

std::atomic<bool> ready(false);

int main ()
{
	unsigned seed = std::chrono::system_clock::now().time_since_epoch().count();
	std::minstd_rand generator(seed);                                                  // minstd_rand is a standard linear_congruential_engine
	const long unsigned int divider = generator.max() / 10;
	const int num = 5;
	std::thread threads[ num ];
	for (int i = 0; i < num; ++i)
	{
		int delay = (generator() / divider + generator.min()) * 200;               // duration for next thread
		threads[i] = std::thread(
			[](int n, int d){
				while (!ready) { std::this_thread::yield(); }              // wait for the ready signal
				std::this_thread::sleep_for(std::chrono::milliseconds(d)); // do something ...
				std::stringstream ss;
				ss << "поток " << n << " завершился через " << d << " мсек." << std::endl;
				std::cout << ss.str();
			}, i, delay                                                        // thread start parameters
		);
		std::cout << "поток " << i << " запущен..." << std::endl;
	}
	ready = true;                                                                      // simultaneous start of threads
	for (int i = 0; i < num; ++i)
		threads[i].join();
	std::cout << "программа завершается" << std::endl;
}

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ make
g++ -Wall -pthread -pedantic -std=c++14 -pthread thread_lambda_r.cc -o thread_lambda_r

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ ./thread_lambda_r
поток 0 запущен...
поток 1 запущен...
поток 2 запущен...
поток 3 запущен...
поток 4 запущен...
поток 4 завершился через 400 мсек.
поток 2 завершился через 600 мсек.
поток 1 завершился через 800 мсек.
поток 0 завершился через 1800 мсек.
поток 3 завершился через 2000 мсек.
программа завершается

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ ./thread_lambda_r
поток 0 запущен...
поток 1 запущен...
поток 2 запущен...
поток 3 запущен...
поток 4 запущен...
поток 2 завершился через 200 мсек.
поток 4 завершился через 600 мсек.
поток 1 завершился через 800 мсек.
поток 0 завершился через 1600 мсек.
поток 3 завершился через 1800 мсек.
программа завершается

Код: Выделить всё

olej@R420:~/2021/OWN_TEST.codes/thread$ ./thread_lambda_r
поток 0 запущен...
поток 1 запущен...
поток 2 запущен...
поток 3 запущен...
поток 4 запущен...
поток 0 завершился через 400 мсек.
поток 1 завершился через 400 мсек.
поток 4 завершился через 1000 мсек.
поток 2 завершился через 1200 мсек.
поток 3 завершился через 2000 мсек.
программа завершается