线程，两个线程之间的通信c＃

Question

我在想什么是在两个线程之间实现通信的最佳方式。我有一个线程生成随机数（类发件人），现在我想有另一个线程（类Receiver），它将接收生成的随机数。 这是发信人：

public class Sender 
{ 
    public int GenerateNumber(){ 


     //some code 
     return randomNumber; 
    } 
} 

Afcourse的主要功能，我会启动这些线程：

static void Main(string[] args){ 

    Sender _sender=new Sender(); 
    Thread thread1=new Thread(new ThreadStart(_sender.GenerateNumber)); 

} 

我感谢你的帮助

Answer 1

您将需要某种资源（列表，队列，等等）在发送者和接收者之间共享。你将不得不同步访问这个资源，否则你将无法在线程之间传递数据。

Answer 2

如果您使用.NET 4，我会建议使用更高级别的抽象：Task<TResult>。您的第一个线程可以安排任务（可能最终创建线程，或者安排在现有的任务处理线程上），然后可以检查状态，阻止结果等。

如果你想要做的不是一次性的任务越多，你可能需要使用一个生产者/消费者队列 - 再次，.NET 4的帮助与通过BlockingCollection<T>。

Answer 3

如果你正在做的是在一个线程中生成一个随机数，我可能会创建一个线程安全对象来代替它。

lock(syncRoot) 
{ 
    myCurrentRandom = Generate(); 
    return myCurrentRandom; 
} 

Answer 4

下面是一个使用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>类上面例子中的等价代码。 NET S 4在Jon Skeet的回答中指出。信用归功于他指出。谢谢，Jon。我还没有理由使用该课程，并且当我看到使用这个课程有多容易时，我感到非常惊喜。

除了使用该课程获得的性能优势之外，使用Task<TResult>类编写等效代码似乎更容易。例如，如下所示的主要方法上面可以改写为体：

 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); 

Answer 5

实现两个线程之间通信的“最佳”方式实际上取决于需要传达的内容。你的例子似乎是一个经典的生产者/消费者问题。我会使用同步队列。查看Synchronized Collections的MSDN文档。您可以使用Queue.Synchronized方法为Queue对象获取同步包装器。然后，让生产者线程调用Enqueue（）和消费者调用Dequeue（）。