C#如何使用Interlocked.CompareExchange

Question

我的目标是：

有一个特定的整数范围，我必须测试这个范围内的每个整数是否有随机性。为此，我想使用多个线程，并使用共享计数器在线程之间平均分配工作。我将计数器设置在起始值，并让每个线程获取一个数字，将其递增，执行一些计算，然后返回结果。此共享计数器必须使用锁来递增，否则将在要测试的整数范围内存在间隙/重叠。

我不知道从哪里开始。假设我想要12个线程来完成这项工作，我做到了：

for (int t = 0; t < threads; t++)
{
  Thread thr = new Thread(new ThreadStart(startThread));
}

startThread()是我用于计算的方法。

你能在路上帮我吗？我知道我必须使用互锁类，但这都是…。

Answer 1

假设你在某个地方有一个int字段(最初初始化为-1 )，那么：

int newVal = Interlocked.Increment(ref theField);

是一个线程安全的增量；假设您不介意溢出int上限的(非常小的)风险，那么：

int next;
while((next = Interlocked.Increment(ref theField)) <= upperInclusive) {
   // do item with index "next"
}

但是，Parallel.For将更方便地完成所有这些工作：

Parallel.For(lowerInclusive, upperExclusive, i => DoWork(i));

或者(限制为12个线程)：

var options = new ParallelOptions { MaxDegreeOfParallelism  = 12 };
Parallel.For(lowerInclusive, upperExclusive, options, i => DoWork(i));