std::condition_variable:: wait_for
|
template
<
class
Rep,
class
Period
>
std::
cv_status
wait_for
(
std::
unique_lock
<
std::
mutex
>
&
lock,
|
(1) | (C++11 이후) |
|
template
<
class
Rep,
class
Period,
class
Predicate
>
bool
wait_for
(
std::
unique_lock
<
std::
mutex
>
&
lock,
|
(2) | (C++11 이후) |
wait_for
는 현재 스레드가 조건 변수가 통지될 때까지, 주어진 지속 시간이 경과할 때까지, 또는 허위 깨어남이 발생할 때까지 차단되도록 합니다.
pred
는 허위 깨어남을 감지하기 위해 선택적으로 제공될 수 있습니다.
wait_for
가 반환된 직후,
lock.
owns_lock
(
)
는
true
이며,
lock.
mutex
(
)
는 호출 스레드에 의해 잠겨 있습니다. 이러한 사후 조건이 충족될 수 없는 경우
[1]
,
std::terminate
를 호출합니다.
다음 조건 중 하나라도 충족되면, 동작은 정의되지 않습니다:
- lock. owns_lock ( ) 가 false 인 경우.
- lock. mutex ( ) 가 호출 스레드에 의해 잠겨 있지 않은 경우.
-
다른 스레드들도
*
this
를 기다리고 있을 때,
lock.
mutex
(
)
가 해당 스레드들이
*
this
에서 호출한 대기 함수들(
wait
,
wait_for및 wait_until )에 의해 잠금 해제된 뮤텍스와 다른 경우.
- ↑ 뮤텍스를 재잠금하는 과정에서 예외가 발생할 경우 이런 상황이 발생할 수 있습니다.
목차 |
매개변수
| lock | - | 호출 스레드가 반드시 잠근 락 |
| rel_time | - | 대기할 최대 지속 시간 |
| pred | - | 대기 완료 여부를 확인할 조건자 |
| 타입 요구사항 | ||
-
Predicate
는
FunctionObject
요구사항을 충족해야 함.
|
||
|
-
|
||
반환값
예외
참고 사항
잠금 상태에서 통지가 되더라도, 오버로드 (1) 는 타임아웃으로 인해 반환될 때 관련된 조건자의 상태에 대해 어떠한 보장도 하지 않습니다.
notify_one()
/
notify_all()
의 효과와
wait()
/
wait_for()
/
wait_until()
의 세 가지 원자적 부분(잠금 해제+대기, 깨어남, 잠금)은
수정 순서
로 볼 수 있는 단일 전체 순서로 발생합니다: 이 순서는 해당 개별 조건 변수에 특정됩니다. 이로 인해
notify_one()
이
예를 들어 지연되어
notify_one()
호출이 이루어진 직후 대기를 시작한 스레드의 차단을 해제하는 것이 불가능해집니다.
예제
#include <chrono> #include <condition_variable> #include <iostream> #include <thread> std::condition_variable cv; std::mutex cv_m; // 이 뮤텍스는 세 가지 목적으로 사용됩니다: // 1) i에 대한 접근 동기화 // 2) std::cerr에 대한 접근 동기화 // 3) 조건 변수 cv를 위한 용도 int i = 0; void waits() { std::unique_lock<std::mutex> lk(cv_m); std::cerr << "Waiting... \n"; cv.wait(lk, []{ return i == 1; }); std::cerr << "...finished waiting. i == 1\n"; } void signals() { std::this_thread::sleep_for(std::chrono::seconds(1)); { std::lock_guard<std::mutex> lk(cv_m); std::cerr << "Notifying...\n"; } cv.notify_all(); std::this_thread::sleep_for(std::chrono::seconds(1)); { std::lock_guard<std::mutex> lk(cv_m); i = 1; std::cerr << "Notifying again...\n"; } cv.notify_all(); } int main() { std::thread t1(waits), t2(waits), t3(waits), t4(signals); t1.join(); t2.join(); t3.join(); t4.join(); }
가능한 출력:
Waiting... Waiting... Waiting... Notifying... Notifying again... ...finished waiting. i == 1 ...finished waiting. i == 1 ...finished waiting. i == 1
결함 보고서
다음의 동작 변경 결함 보고서들은 이전에 발표된 C++ 표준에 소급 적용되었습니다.
| DR | 적용 대상 | 게시된 동작 | 올바른 동작 |
|---|---|---|---|
| LWG 2093 | C++11 | 타임아웃 관련 예외가 명세에 누락됨 | 해당 예외들을 명시함 |
|
LWG 2114
( P2167R3 ) |
C++11 | bool 변환 가능성이 구현들의 기대를 반영하기에 너무 약함 | 요구 사항 강화됨 |
| LWG 2135 | C++11 | lock. lock ( ) 가 예외를 발생시킬 경우 동작이 불명확함 | 이 경우 std::terminate 호출 |
참고 항목
|
현재 스레드를 조건 변수가 깨어날 때까지 블록합니다
(public member function) |
|
|
현재 스레드를 조건 변수가 깨어나거나 지정된 시간 점에 도달할 때까지 블록합니다
(public member function) |