我有一个 ushort 计数器(偶尔会翻转)。使用这个值的消息传递协议(protocol)不允许 0。我需要一些线程安全的方法来增加这个计数器(存储在类字段中)每次读取它,如果我将它存储为 int 并使用互锁。增量。但是,我不确定如何将跳过 0 合并到其中。偶尔跳过几个数字也没关系;我的输出序列不一定是完美的。我不能在任何 4000 block 中重复使用相同的数字。我想避免使用锁。
请您参考如下方法:
这个:
给定:
static int value = ushort.MaxValue;
在代码中:
int temp, temp2;
do
{
temp = value;
temp2 = temp == ushort.MaxValue ? 1 : temp + 1;
}
while (Interlocked.CompareExchange(ref value, temp2, temp) != temp);
你必须使用 int 然后转换它(例如在 get 属性中),因为 Interlocked 不是t 用于所有基本类型。
我们可能会在像这样的高度线程化的上下文中让它更快一些:
int temp = value;
while (true)
{
int temp2 = temp == ushort.MaxValue ? 1 : temp + 1;
int temp3 = Interlocked.CompareExchange(ref value, temp2, temp);
if (temp3 == temp)
{
break;
}
temp = temp3;
}
这样我们就可以少读一次失败了。
正如我在评论中所写,这段代码的中心思想是增加一个临时变量 (temp2) 计数器,然后尝试将我们知道的旧值与新值 (Interlocked.CompareExchange)。如果没有人触及中间的旧值 (Interlocked.CompareExchange() == temp),那么我们就完成了。如果其他人增加了值(value),那么我们再做一次尝试。 ushort 是通过使用具有固定最大值的 int 来模拟的 (temp == ushort.MaxValue ? 1 : temp + 1) .
第二个版本,在 Interlocked.CompareExchange() 失败时重新使用函数读取的值作为加 1 的新基础。
以这种方式使用的 Interlocked.CompareExchange 可以用作构建其他 Interlocked 操作的基础(您需要一个 Interlocked.Multiply ? 你做一个“标准”乘法,然后尝试 Interlocked.CompareExchange 旧值)
