我怎样才能确保只有一个线程会做某事？

Question

我有多个线程将项目添加到无锁队列中。
然后这些项目由另一个线程处理。

在生产者线程中，我需要启动消费者线程，但前提是它尚未运行或启动。

具体来说：

public void BeginInvoke(Action method)
{
    //This runs on multiple background threads
    pendingActions.Enqueue(method);
    if (ProcessQueue hasn't been posted)
        uiContext.Post(ProcessQueue, null);
}
private void ProcessQueue(object unused)
{
    //This runs on the UI thread.
    Action current;
    while (pendingActions.TryDequeue(out current))
        current();
}

我使用的是.Net 3.5，而不是4.0。 :(

Answer 1

最简单的方法是使用信号量。它将有队列大小的计数。

Answer 2

我创建了以下类来执行此操作：

///<summary>Ensures that a block of code is only executed once at a time.</summary>
class Valve
{
    int isEntered;  //0 means false; 1 true

    ///<summary>Tries to enter the valve.</summary>
    ///<returns>True if no other thread is in the valve; false if the valve has already been entered.</returns>
    public bool TryEnter()
    {
        if (Interlocked.CompareExchange(ref isEntered, 1, 0) == 0)
            return true;
        return false;
    }

    ///<summary>Allows the valve to be entered again.</summary>
    public void Exit()
    {
        Debug.Assert(isEntered == 1);
        isEntered = 0;
    }
}

我像这样使用它：

readonly Valve valve = new Valve();
public void BeginInvoke(Action method)
{
    pendingActions.Enqueue(method);
    if (valve.TryEnter())
        uiContext.Post(ProcessQueue, null);
}
private void ProcessQueue(object unused)
{
    //This runs on the UI thread.
    Action current;
    while (pendingActions.TryDequeue(out current))
        current();
    valve.Exit();
}

此模式安全吗？
有更好的方法吗？
班级有更正确的名称吗？

Answer 3

这对你有用吗？

volatile int running;  //not a boolean to allow ProcessQueue to be reentrant.

private void ProcessQueue(object unused)
{
    do
    {
        ++running;
        Action current;
        while (pendingActions.TryDequeue(out current))
            current();

        --running;
    }
    while (pendingActions.Count != 0);
} 

public void BeginInvoke(Action method) 
{     
    pendingActions.Enqueue(method);
    if (running != 0)
        uiContext.Post(ProcessQueue, null); 
} 

Answer 4

创建第二个 调度程序< /a> 用于消费者线程。然后，生产者线程可以使用该调度程序的 BeginInvoke() 方法将数据发送到消费者线程。 Dispatcher 的队列取代了pendingActions 队列，并确保使用者线程一次仅处理一个工作项。

与其让生产者线程尝试协调消费者线程的启动和停止，不如在启动任何生产者之前启动消费者线程，并让它闲置。调度程序应该在需要时自动唤醒它。