这些atomic_compare_exchange_XXX
函数用观察到的值更新它们的“预期”参数,因此您的循环与以下内容相同:
expected = current;
do {
desired = f(expected);
} while (!current.atomic_compare_exchange_weak(expected, desired));
如果期望值独立于期望值,则此循环变为:
desired = ...;
expected = current;
while (current.atomic_compare_exchange_weak(expected, desired))
;
让我们添加一些语义。假设有几个线程同时运行它。在每种情况下desired
都是当前线程的非零 ID,current
用于提供互斥以确保某些线程执行清理任务。我们并不真正关心哪一个,但我们想确保某个线程可以访问(并且也许其他线程可以通过读取它的 ID 来观察获胜者current
)。
我们可以通过以下方式实现所需的语义:
expected = 0;
if (current.atomic_compare_exchange_strong(expected, this_thread)) {
// I'm the winner
do_some_cleanup_thing();
current = 0;
} else {
std::cout << expected << " is the winner\n";
}
这是一种atomic_compare_exchange_weak
需要循环来实现与 相同的效果的情况atomic_compare_exchange_strong
,因为可能会出现虚假故障:
expected = 0;
while(!current.atomic_compare_exchange_weak(expected, this_thread)
&& expected == 0))
;
if (expected == this_thread) {
do_some_cleanup_thing();
current = 0;
} else {
std::cout << expected << " is the winner\n";
}
该标准建议在这种情况下,实现可以提供atomic_compare_exchange_strong
比循环更有效的代码..._weak
(§29.6.5/25 [atomics.types.operations.req])。