Параллельное программирование на С++ в действии. Практика разработки многопоточных программ | страница 31



Именно здесь и оказывается полезной поддержка классом >std::thread семантики перемещения. В предыдущем разделе отмечалось, что в стандартной библиотеке С++ есть много типов, владеющих ресурсами, например >std::ifstream и >std::unique_ptr, которые являются перемещаемыми, но не копируемыми, и один из них — >std::thread. Это означает, что владение потоком можно передавать от одного экземпляра >std::thread другому, как показано в примере ниже. В нем создается два потока выполнения, владение которыми передается между тремя объектами >std::thread: >t1, >t2 и >t3.

>void some_function();

>void some_other_function();


>std::thread t1(some_function);         ←(1)

>std::thread t2 = std::move(t1);        ←(2)

>t1 = std::thread(some_other_function); ←(3)

>std::thread t3;     ←(4)

>t3 = std::move(t2); ←(5)

>t1 = std::move(t3); ←(6) Это присваивание приводит

>;                       к аварийному завершению программы

Сначала создастся новый поток (1) и связывается с объектом >t1. Затем владение явно передается объекту >t2 в момент его конструирования путем вызова >std::move()(2). В этот момент с >t1 уже не связан никакой поток выполнения: поток, в котором исполняется функция >some_function, теперь связан с >t2.

Далее создается еще один поток, который связывается с временным объектом типа >std::thread(3). Для последующей передачи владения объекту >t1 уже не требуется явный вызов >std::move(), так как владельцем является временный объект, а передача владения от временных объектов производится автоматически и неявно.

Объект >t3 конструируется по умолчанию (4), а это означает, что в момент создания с ним не связывается никакой поток. Владение потоком, который в данный момент связан с >t2, передастся объекту >t3(5), опять-таки путем явного обращения к >std::move(), поскольку >t2 — именованный объект. После всех этих перемещений >t1 оказывается связан с потоком, исполняющим функцию >some_other_function, >t2 не связан ни с каким потоком, a >t3 связан с потоком, исполняющим функцию >some_function .

Последнее перемещение (6) передает владение потоком, исполняющим >some_function, обратно объекту >t1, в котором исполнение этой функции началось. Однако теперь с >t1 уже связан поток (который исполнял функцию >some_other_function), поэтому вызывается >std::terminate(), и программа завершается. Так делается ради совместимости с поведением деструктора >std::thread. В разделе 2.1.1 мы видели, что нужно либо явно ждать завершения потока, либо отсоединить его до момента уничтожения; то же самое относится и к присваиванию: нельзя просто «прихлопнуть» поток, присвоив новое значение объекту