我想知道在两个线程之间实现通信的最佳方法是什么。我有一个生成随机数的线程（Sender类），现在我想要另一个接收生成的随机数的线程（Receiver类）。
这是Sender：
public class Sender
{
public int GenerateNumber(){
//some code
return randomNumber;
}
}
当然，在主函数中我会启动那些线程：
static void Main(string[] args){
Sender _sender=new Sender();
Thread thread1=new Thread(new ThreadStart(_sender.GenerateNumber));
}
感谢你的帮助
Task<TResult>。您的第一个线程可以调度任务（可能会创建一个线程，或被调度到现有的任务处理线程上），然后可以根据需要检查状态、阻塞结果等。BlockingCollection<T>帮助实现这一点。Task<T>内容... 通过MSDN博客文章研究任务并行库可能比阅读这本书更有直接的好处。当然，我并不会长期阻止你 :) - Jon Skeet以下是一种可能的方法，使用WaitHandle：
class Program
{
static void Main(string[] args)
{
Sender _sender = new Sender();
Receiver _receiver = new Receiver();
using (ManualResetEvent waitHandle = new ManualResetEvent(false))
{
// have to initialize this variable, otherwise the compiler complains when it is used later
int randomNumber = 0;
Thread thread1 = new Thread(new ThreadStart(() =>
{
randomNumber = _sender.GenerateNumber();
try
{
// now that we have the random number, signal the wait handle
waitHandle.Set();
}
catch (ObjectDisposedException)
{
// this exception will be thrown if the timeout elapses on the call to waitHandle.WaitOne
}
}));
// begin receiving the random number
thread1.Start();
// wait for the random number
if (waitHandle.WaitOne(/*optionally pass in a timeout value*/))
{
_receiver.TakeRandomNumber(randomNumber);
}
else
{
// signal was never received
// Note, this code will only execute if a timeout value is specified
System.Console.WriteLine("Timeout");
}
}
}
}
public class Sender
{
public int GenerateNumber()
{
Thread.Sleep(2000);
// http://xkcd.com/221/
int randomNumber = 4; // chosen by fair dice role
return randomNumber;
}
}
public class Receiver
{
public void TakeRandomNumber(int randomNumber)
{
// do something
System.Console.WriteLine("Received random number: {0}", randomNumber);
}
}
Task<TResult>类的等效代码。感谢他指出这一点。非常感谢你，Jon。我之前没有使用过这个类，并且当我看到它有多么容易使用时，感到非常惊喜。
除了在底层获得性能优势之外，使用Task<TResult>类编写等效代码似乎更加简单。例如，上面Main方法的主体可以重写如下：
Sender _sender = new Sender();
Receiver _receiver = new Receiver();
Task<int> getRandomNumber = Task.Factory.StartNew<int>(_sender.GenerateNumber);
// begin receiving the random number
getRandomNumber.Start();
// ... perform other tasks
// wait for up to 5 seconds for the getRandomNumber task to complete
if (getRandomNumber.Wait(5000))
{
_receiver.TakeRandomNumber(getRandomNumber.Result);
}
else
{
// the getRandomNumber task did not complete within the specified timeout
System.Console.WriteLine("Timeout");
}
如果您不需要为任务指定超时并愿意无限期地等待它完成，那么您可以使用更少的代码编写：
Sender _sender = new Sender();
Receiver _receiver = new Receiver();
Task<int> getRandomNumber = Task.Factory.StartNew<int>(_sender.GenerateNumber);
// begin receiving the random number
getRandomNumber.Start();
// ... perform other tasks
// accessing the Result property implicitly waits for the task to complete
_receiver.TakeRandomNumber(getRandomNumber.Result);
Task<TResult>类以更少的代码完成相同的事情。 - Dr. Wily's Apprentice实现两个线程之间的通信，最好的方法取决于需要通信的内容。你的例子似乎是一个经典的生产者/消费者问题。我建议使用同步队列。请参考MSDN文档中的同步集合。你可以使用Queue.Synchronized方法来获取一个Queue对象的同步包装器。然后，生产者线程调用Enqueue()，消费者线程调用Dequeue()。
lock(syncRoot)
{
myCurrentRandom = Generate();
return myCurrentRandom;
}
int randomNumber = 4; // chosen by fair dice roll.- Dr. Wily's Apprentice