在.NET中并发线程之间传递数据的最佳方法是什么？

Question

我有两个线程，一个需要轮询一堆独立的静态资源来寻找更新。另一个需要获取数据并将其存储在数据库中。线程1如何告诉线程2有什么要处理？

Answer 1

如果数据片段是独立的，则将数据片段视为要由线程池处理的工作项。使用线程池和 QueueUserWorkItem 将数据发布到线程。您应该使用对称线程池来获得更好的可伸缩性，并限制生产者和消费者之间必须发生的同步量。

例如（来自 MSDN ）：

    TaskInfo ti = new TaskInfo("This report displays the number {0}.", 42);

    // Queue the task and data.
    if (ThreadPool.QueueUserWorkItem(new WaitCallback(ThreadProc), ti)) {    
        Console.WriteLine("Main thread does some work, then sleeps.");

        // If you comment out the Sleep, the main thread exits before
        // the ThreadPool task has a chance to run.  ThreadPool uses 
        // background threads, which do not keep the application 
        // running.  (This is a simple example of a race condition.)
        Thread.Sleep(1000);

        Console.WriteLine("Main thread exits.");
    }
    else {
        Console.WriteLine("Unable to queue ThreadPool request."); 
    }


// The thread procedure performs the independent task, in this case
// formatting and printing a very simple report.
//
static void ThreadProc(Object stateInfo) {
    TaskInfo ti = (TaskInfo) stateInfo;
    Console.WriteLine(ti.Boilerplate, ti.Value); 
}

Answer 2

我在工作项的队列中使用Monitor.Wait / Pulse。

Answer 3

“存储在数据库中”是否存在？线程总是需要运行？似乎最好的选择（如果可能的话）是让轮询线程旋转另一个线程来进行保存。根据创建的线程数，可能是第一个轮询线程使用ThreadPool.QueueUserWorkItem（）可能是更有效的路由。

为了提高效率，在保存到数据库时，我会在数据库上使用异步I / O而不是同步方法。

任何时候你都可以避免在两个线程之间直接通信，你应该这样做。必须将一些同步原语放在一起，你的代码将不会那么容易调试，并且可能会引入一些非常微妙的竞争条件，导致“一百万次执行”。键入错误（找到/修复很有趣）。

如果第二个线程总是需要执行，请告诉我们为什么要提供更多信息，我们可以回过头来进行更深入的回答。

祝你好运！

Answer 4

我个人会有线程1引发线程2可以响应的事件。线程可以通过控制进程连接到适当的事件，从而启动两个线程。