需要简单的线程示例

Question

考虑到以下要求，有人可以发布一个非常简单的代码示例，说明如何使用多线程，同时正确利用锁来保持共享数据的“安全”？

假设您将整数 x 声明为 100。然后，您想要生成 10 个线程，每个线程执行一些操作。当每个线程完成操作时，它会递减 x。我知道您可以为此使用互锁，但是在评估条件时您是否也需要锁？换句话说，在执行操作之前，您需要确保 x 大于 0。

Answer 1

您可以使用 lock 关键字包装对 x 的每次访问：

private object xLock = new object();

...

lock (xLock)
{
   // Any read or write access to x
}

这将确保对 x 的所有访问都是原子的，并且不存在与线程安全相关的危险。

Answer 2

如果您想编写简单的多线程程序，请考虑使用 C# 4.0 中的并行扩展。

具有锁和可变共享数据的普通多线程程序绝不简单。

Answer 3

您可能不想在操作完成后递减计数器，因为计数器可能为 1，所有 10 个线程都会检查它，发现它大于零，然后开始执行操作，只有在完成时才将其递减。

您可以使用 Interlocked.Decrement 来减少计数器并在之前检查其值在不锁定的情况下执行操作：

int temp = Interlocked.Decrement(x);

if(temp >= 0) //temp is the decremented value
{
    //perform action
}

Answer 4

您想要使用Interlocked.CompareExchange。假设您要修改一个名为 Counter 的共享变量。

int count = Counter;
if (count == 0)
    return;
if (Interlocked.CompareExchange(ref Counter, count-1, count) == count)
{
    // Counter was decremented.
    // perform your processing.
}

如果您希望线程在退出之前处理最多 10 个项目，则可以将其包装在循环中。

请注意，计数器控制处理方法的进入。也就是说，从逻辑上讲，它的工作原理如下：

if (counter > 0)
{
    --counter;
    DoAction();
}

您的问题似乎要求类似以下内容：

if (counter > 0)
{
    DoAction();
    --counter;
}

但如果您以这种方式编码，那么您可能会调用 DoAction 超过 100 次（或任何初始值） counter 是），因为其他线程可以在最后一个线程完成之前开始该操作。

Answer 5

如果你想做你自己的事情，只需实现你自己的逻辑

lock(somecommonreference)
{
   if (x>0) x--;
}