用任务替换无限线程循环（消息泵）

在我的应用程序中，我必须侦听多个不同的队列并反序列化/调度在队列上接收到的传入消息。用任务替换无限线程循环（消息泵）

实际上，我在做什么来实现这一目标是每个QueueConnector对象在构造时创建一个新线程，该线程通过对queue.Receive（）的阻塞调用执行一个无限循环，以接收队列中的下一条消息，下面的代码：

// Instantiate message pump thread 
msmqPumpThread = new Thread(() => while (true) 
{ 
    // Blocking call (infinite timeout) 
    // Wait for a new message to come in queue and get it 
    var message = queue.Receive(); 

    // Deserialize/Dispatch message 
    DeserializeAndDispatchMessage(message); 
}).Start();

我想知道，如果这个“消息泵”，可以使用任务（一个或多个）所取代，而不是通过一个新的线程无限循环下去。

我已经为消息接收部分做了一个任务（见下面），但我真的不知道如何将它用于消息泵（我可以一遍又一遍记得一遍又一遍地完成同一个任务，在代码替换单独的线程无限循环如上？）

Task<Message> GetMessageFromQueueAsync() 
{ 
    var tcs = new TaskCompletionSource<Message>(); 

    ReceiveCompletedEventHandler receiveCompletedHandler = null; 

    receiveCompletedHandler = (s, e) => 
    { 
     queue.ReceiveCompleted -= receiveCompletedHandler; 
     tcs.SetResult(e.Message); 
    }; 

    queue.BeginReceive(); 

    return tcs.Task; 
}

我将获得通过使用任务而不是无限循环的任何一个单独的线程（在此上下文中，阻塞调用=>阻塞线程）？如果是的话，如何正确地做到这一点？

请注意，此应用程序没有很多QueueConnector对象，并且不会有（可能有10个连接器MAX），这意味着通过第一个解决方案的最大线程数为10，因此内存占用量/性能启动线程不是问题在这里。我宁愿考虑调度性能/ CPU使用率。会有什么区别吗？

来源

2012-07-05 darkey

这是一个tipycal生产者 - 消费者场景，可以使用['BlockingCollection']（http://msdn.microsoft.com/en-us/library/dd267312.aspx）解决，特别是使用['BlockingCollection 。GetConsumingEnumerable']（http://msdn.microsoft.com/en-us/library/dd287186.aspx） – 2012-07-05 18:26:49

感谢Paolo！但据我所知，生产者/消费者队列更适合于计算绑定任务（执行密集计算），而TaskCompletionSource /异步函数更适合于I/O绑定任务（等待发生的事情）。由于我的问题处理I/O绑定任务（等待消息进入队列），我认为TaskCompletionSource会更加合适。然而，我可能是错的。 – darkey 2012-07-05 21:29:56

当线程数很少时，通常会有更多的开销和更少的吞吐量与异步代码。当线程数量非常大时，非阻塞代码非常有用，这导致a）由于堆栈和b）上下文切换造成的大量浪费内存。尽管由于更多的分配，更多的间接性和更多的用户内核转换，它具有明显的开销。

对于低线程数（< 100），您可能不应该担心。尽量专注于编写可维护，防错和简单的代码。使用线程。

来源

2012-07-05 20:12:42 usr

感谢您的回答。尽管如果每个QueueConnector对象使用一个具有无限循环的专用线程来接收消息（我当前的方法），线程每次到达阻塞队列.Receive（）调用时都会执行上下文切换。一旦消息到达，另一个上下文切换回线程。那是对的吗？我读过任务可以使用线程池减少启动延迟（在我的上下文中不需要），但也与TaskCompletionSource他们可以使用回调方法，避免使用线程等待I/O绑定操作没有上下文切换？） – darkey 2012-07-05 21:38:34

异步非阻塞代码导致较少的上下文切换。如果你想资助哪个版本更快，你需要尝试一下，因为有两个参数。我的观点是，这可能是不值得的麻烦。你每秒有多少队列操作？小于10K？那从perf的角度来看并不重要。 – usr 2012-07-06 07:38:02

用任务替换无限线程循环（消息泵）

回答

相关问题