在另一个线程中处理异步结果

Question

我有一个 WinCE C# 应用程序，它轮询 (JAVA) 服务器以获取异步传入的消息。我想要实现的是我想轮询服务器，当返回结果时，将其排队，然后在另一个线程中处理该结果。我想将异步接收线程与进程线程隔离开来，因为在处理响应之后，我可能需要向服务器发送额外的 POST。

我现在拥有的是一个类似于这里显示的类

http://msdn.microsoft.com/en-us/library/86wf6409%28v=vs.80%29.aspx

用于向服务器发出异步请求并读取响应。我已经修改了该类以包含自定义超时，但这无关紧要。

在我的应用程序中发生的情况是，我开始在线程“pollingThread”中进行轮询，并从服务器获取响应。如果超时，响应将为空，否则我尝试处理响应。

我想将响应字符串发送给另一个可以处理它的线程，而我的 pollingThread 会返回继续轮询服务器。我不知道如何将响应发送到另一个线程。我知道如何在大窗口上使用 Monitor.Pulse，但不幸的是它在 NETCF 3.5 上不可用。

有什么见解吗？

谢谢

编辑：@Damon8or

我尝试使用 AutoReset 但由于某种原因，WaitOne() 没有意识到另一个线程已经 Set() 事件，因此它错过了通过的数据。这是我所拥有的：

AutoresetEvent _process 被声明为静态并且对两种方法都可见

ThreadStart processMethod= new ThreadStart(process);
processingThread= new Thread(processJSONMethod);
processingThread.IsBackground = true;
processingThread.Start();

ThreadStart startMethod = new ThreadStart(Poll);
connectionThread = new Thread(startMethod);
connectionThread.IsBackground = true;                    
connectionThread.Start();

在投票内部，我收到来自服务器的字符串后有_process.Set()。在处理方法中，我有：

while (_keepPolling)
{

_process.WaitOne();

string text= MyQueue.Dequeue();
Debug.WriteLine("Returned: " + text

}    

而且我没有看到正在打印的调试行。 poll 方法生成字符串并将其排队，然后返回轮询。

Answer 1

您可以使用 AutoResetEvent 或 ManualResetEvent 向您的工作线程发出信号。下面是一个简单的例子。

    using System; 
    using System.Linq; 
    using System.Collections.Generic; 
    using System.Text; 
    using System.Threading; 

    namespace QueueDoodles 
    {
    class Program
    {
        public static readonly string[] data = { "a", "b", "c", "d", "e", "f", "g", "h" };

        static void Main(string[] args)
        {
            var running = true;
            var rand = new Random();
            var q = new Queue<string>();
            var qEvent = new ManualResetEvent(false);
            var pollThread = new Thread(new ThreadStart(delegate()
            {
                while (running)
                {
                    // Queue the next value
                    var value = data[rand.Next(data.Length)];
                    q.Enqueue(value);
                    Console.WriteLine("{0} queued {1}", Thread.CurrentThread.Name, value);

                    // Signal waiting thread
                    qEvent.Set();

                    // Simulate polling
                    Thread.Sleep(rand.Next(100));
                }
            }));
            pollThread.Name = "Poll Thread";

            var workerThread = new Thread(new ThreadStart(delegate()
            {
                while (running)
                {
                    // Wait on the queue
                    if (!qEvent.WaitOne())
                        break;
                    qEvent.Reset();

                    // Process the next queue item
                    var value = q.Dequeue();
                    Console.WriteLine("{0} queued {1}", Thread.CurrentThread.Name, value);
                }
            }));
            workerThread.Name = "Worker Thread";

            // Start the poll thread
            pollThread.Start();

            // Give it some time to fill queue
            Thread.Sleep(1000);

            // Start the worker thread
            workerThread.Start();

            // Wait for keyboard input
            Console.ReadLine();
            running = false;
            qEvent.Set();
        }
    }
}

Answer 2

队列类是线程安全的，为什么不使用队列来对数据进行排队呢？

http://msdn.microsoft.com/en-us/library/system.collections.queue.aspx