[C++] jthread

개요

• thread와 일반적으로는 동일
• destruction 시 자동으로 다시 join
• 특정 상황에서 중지 가능
• 공유 중지 상태를 유지하는 stop_source 타입의 private 멤버를 내부적으로 가짐
  • 생성자는 stop_token을 첫 번째 인수로 사용하는 함수를 허용
  • 함수는 실행 중에 중지가 요청되었는지 확인하고 요청된 경우 반환 가능
• 멤버 함수
  • stop token handling
    • get_stop_source()
      • 스레드의 공유 중지 상태와 관련된 stop_source 객체를 반환
    • get_stop_token()
      • 스레드의 공유 중지 상태와 관련된 stop_token을 반환
    • request_stop()
      • 스레드의 공유 중지 상태를 통해 실행 중지를 요청
      • destruction 시 request_stop()를 호출하고 이미 호출 했다면 무시

예제

• 코드

   #include <chrono>
   #include <iostream>
   #include <thread>
      
   using namespace std;
      
   int main() {
   	auto test1 = []() {
   		// automatically rejoins on destruction
   		jthread([]() { cout << "1" << endl; });
   	};
   	test1();
      
   	cout << endl << "------" << endl << endl;
      
   	auto test2 = []() {
   		jthread t([](stop_token token) {
   			cout << "1" << endl;
      
   			using namespace chrono_literals;
   			this_thread::sleep_for(1s);
      
   			if (token.stop_requested()) {
   				cout << "stop" << endl;
   				return;
   			}
      
   			cout << 2 << endl;
   		});
      
   		cout << 3 << endl;
      
   		t.join();
   	};
   	test2();
      
   	cout << endl << "------" << endl << endl;
      
   	auto test3 = []() {
   		jthread t([](stop_token token) {
   			cout << "1" << endl;
   			using namespace chrono_literals;
   			this_thread::sleep_for(1s);
      
   			if (token.stop_requested()) {
   				cout << "stop" << endl;
   				return;
   			}
      
   			cout << 2 << endl;
   		});
      
   		t.request_stop();
   		t.join();
      
   		cout << 3 << endl;
   	};
   	test3();
      
   	return 0;
   }
  

• 실행 결과

   1
      
   ------
      
   3
   1
   2
      
   ------
      
   1
   stop
   3