C 多线程 std::call_once{} and std::once_flag1. std::call_once()1.1. std::once_flag2. Parameters3. Return value4. Examples4.1. std::call_once()5. Data races (数据竞争)6. Exception safety (异常安全性)Referenceshttps://cplusplus.com/reference/mutex/call_once/1.std::call_once()public member functiontemplate class Fn, class... Args void call_once (once_flag flag, Fn fn, Args... args);std::call_once()是 C11 引入的一个线程同步原语用于确保在多线程环境中某个特定的函数或初始化代码块‌仅被执行一次‌无论有多少个线程同时调用它。多个线程同时调用std::call_once()时只有一个线程会执行目标函数其他线程会被阻塞直到该函数执行完毕。Callsfnpassingargsas arguments, unless another thread has already executed (or is currently executing) a call tostd::call_once()with the samestd::once_flag.调用函数fn并传递args作为参数除非另一个线程已经执行过 (或正在执行) 使用相同std::once_flag调用std::call_once()的操作。If another thread is already actively executing a call tostd::call_once()with the samestd::once_flag, it causes a passive execution: Passive executions do not callfnbut do not return until the active execution itself has returned, and all visible side effects are synchronized at that point among all concurrent calls to this function with the samestd::once_flag.std::call_once()将检查关联的std::once_flag是否已被标记为执行过如果没有执行过则std::call_once()会执行传入的函数并将标记设置为已执行保证此后的调用不会再次执行该函数。如果已执行过则std::call_once()不会执行传入的函数。passive [pæsɪv] n. 被动语态动词被动形式 adj. 消极的被动的(动词形式) 被动语态的If an active call tostd::call_once()ends by throwing an exception (which is propagated to its calling thread) and passive executions exist, one is selected among these passive executions, and called to be the new active call instead.如果对std::call_once()的活动调用因抛出异常而终止 (该异常会传播到调用线程)并且存在被动执行则会从这些被动执行中选择一个并将其作为新的活动调用来执行。Note that once an active execution has returned, all current passive executions and future calls tostd::call_once()(with the samestd::once_flag) also return without becoming active executions.一旦某个活动执行完成并返回所有当前的被动执行以及将来对std::call_once()的调用 (使用相同的std::once_flag) 也会立即返回而不会成为活动执行。The active execution usesstd::decayof thelvalueorrvaluereferences offnandargs, ignoring the value returned byfn.1.1.std::once_flagstruct once_flag;Object of this type are used as arguments forstd::call_once().Using the same object on different calls tostd::call_once()in different threads causes a single execution if called concurrently.It is a non-copyable, non-movable, default-constructible class, declared inmutexwith the following prototype:// STRUCT once_flag struct once_flag { // opaque data structure for call_once() constexpr once_flag() _NOEXCEPT : _Opaque(0) { // default construct } once_flag(const once_flag) delete; once_flag operator(const once_flag) delete; void *_Opaque; };2. ParametersflagObject used by the function to track the state of invocations.Using the same object for calls in different threads, results in a single call if called concurrently.C11: Ifflaghas a state that is not valid, the function throws astd::system_errorexception with anstd::errc::invalid_argumenterror condition.C14: Ifflaghas a state that is not valid, the call causes undefined behavior.std::call_once()is a specific type defined in headermutexto be used as argument to this function.std::once_flag应当与需要单次执行的函数或者代码块保持相同的生命周期通常作为静态状态存在于全局或者作为某个对象的一部分。一旦被std::call_once()标记为已调用它的状态就不会再变更确保生命周期的管理不会影响其功能。fnA pointer to function, pointer to member, or any kind ofstd::is_move_constructiblefunction object (i.e., an object whose class definesoperator(), including closures andstd::functionobjects).The return value (if any) is ignored.args...Arguments passed to the call tofn. Their types shall bestd::is_move_constructible.Iffnis astd::is_member_pointer, the first argument shall be an object for which that member is defined (or a reference, or a pointer to it).3. Return valuenone4. Examples4.1.std::call_once()// // Name : std::call_once() // Author : Yongqiang Cheng // Version : Version 1.0.0 // Copyright : Copyright (c) 2019 Yongqiang Cheng // Description : Hello World in C, Ansi-style // #include iostream #include thread #include chrono #include mutex int winner; void set_winner(const int x) { winner x; } std::once_flag winner_flag; void wait_1000ms(const int id) { // count to 1000, waiting 1ms between increments: for (int i 0; i 1000; i) { std::this_thread::sleep_for(std::chrono::milliseconds(1)); } // claim to be the winner (only the first such call is executed): std::call_once(winner_flag, set_winner, id); } int main() { std::thread threads[10]; // spawn 10 threads: for (int i 0; i 10; i) { threads[i] std::thread(wait_1000ms, i 1); } std::cout waiting for the first among 10 threads to count 1000 ms...\n; for (auto th : threads) { th.join(); } std::cout winner thread: winner \n; return 0; }Possible output (winner may vary):waiting for the first among 10 threads to count 1000 ms... winner thread: 9 请按任意键继续. . .5. Data races (数据竞争)The function modifiesstd::once_flag, and accessesfnandargsto createstd::decayof theirlvalueorrvaluereferences.6. Exception safety (异常安全性)If the function itself fails, it throws astd::system_errorexception, leaving all objects in a valid state (basic guarantee).Otherwise, active executions provide the same level of guarantees as the operation performed on the arguments.References[1] Yongqiang Cheng, https://yongqiang.blog.csdn.net/[2]std::call_once(), https://cplusplus.com/reference/mutex/call_once/[3]std::once_flag, https://cplusplus.com/reference/mutex/once_flag/