返回两个长时间运行的方法的值，使用线程

Question

我有一个线程连接到两个网络资源。每次尝试连接时，回复可能需要10秒。

void MyThread() 
{ 
    //this takes ten seconds 
    Resource r1 = MySystem.GetResource(ipAddress1); 

    //this takes ten seconds 
    Resource r2 = MySystem.GetResource(ipAddress2); 

    //do stuff with ep1 and ep2 
} 

总时间二十岁秒，但我真的很喜欢它只拿10秒 - 启动线程每个我叫占用资源的时间，收到答复，然后加入每个线程返回控制。

这样做的最好方法是什么？启动两个线程，每个线程都返回一个值？引用局部变量的匿名方法？我的头在旋转。代码表示赞赏。

Answer 1

如何

Resource r1 = null; // need to initialize, else compiler complains 
Resource r2 = null; 

ThreadStart ts1 = delegate { 
    r1 = MySystem.GetResource(ipAddress1); 
}; 
ThreadStart ts2 = delegate { 
    r2 = MySystem.GetResource(ipAddress2); 
}; 
Thread t1 = new Thread(ts1); 
Thread t2 = new Thread(ts2); 
t1.Start(); 
t2.Start(); 
// do some useful work here, while the threads do their thing... 
t1.Join(); 
t2.Join(); 
// r1, r2 now setup 

简短而甜美。

Answer 2

请在MSDN上尝试此操作：“使用委托的异步编程”。

http://msdn.microsoft.com/en-us/library/22t547yb.aspx

-Oisin

Answer 3

是发生在我这样做最简单的方法是同时具有主线程中执行第二初始化并等待并行调用的一个上一个工作线程。下面snipet应有助于说明：

ManualResetEvent r1Handle = new ManualResetEvent(false); 
Resource   r1  = null; 
Resource   r2  = null; 

// Make the threadpool responsible for populating the 
// first resource. 

ThreadPool.QueueUserWorkItem((state) => 
{ 
    r1 = MySystem.GetResource(ipAddress1); 

    // Set the wait handle to signal the main thread that 
    // the work is complete. 

    r1Handle.Set(); 
}); 

// Populate the second resource. 

r2 = MySystem.GetResource(ipAddress2); 

// Wait for the threadpool worker to finish. 

r1Handle.WaitOne(); 

// ... Do more stuff 

对于线程同步技术的更详细的讨论，你不妨请访问MSDN文章的题目是http://msdn.microsoft.com/en-us/library/ms173179.aspx

Answer 4

这些总是有趣的问题来思考，当然有多种方法来解决它。

对我来说很好的一种方法是提供一个回调方法，每个线程都使用回调方法来返回结果和状态。在下面的示例中，我使用List来跟踪正在运行的线程并将结果放入Dictionary中。

using System; using System.Collections.Generic; 使用System.Linq的; 使用System.Text;使用System.Threading的 ;使用System.Timers的 ;

命名空间ConsoleApplication1 { 类节目 { 静态字典threadResults =新词典（）; static int threadMax = 2;

static void Main(string[] args) 
    { 
     List<Thread> runningThreads = new List<Thread>(); 
     for (int i = 0; i < threadMax; i++) 
     { 
      Worker worker = new Worker(); 
      worker.Callback = new Worker.CallbackDelegate(ThreadDone); 
      Thread workerThread = new Thread(worker.DoSomething); 
      workerThread.IsBackground = true; 
      runningThreads.Add(workerThread); 
      workerThread.Start(); 
     } 

     foreach (Thread thread in runningThreads) thread.Join(); 
    } 

    public static void ThreadDone(int threadIdArg, object resultsArg) 
    { 
     threadResults[threadIdArg] = resultsArg; 
    } 
} 


class Worker 
{ 
    public delegate void CallbackDelegate(int threadIdArg, object resultArg); 
    public CallbackDelegate Callback { get; set; } 
    public void DoSomething() 
    { 
     // do your thing and put it into results 
     object results = new object(); 
     int myThreadId = Thread.CurrentThread.ManagedThreadId; 
     Callback(myThreadId, results); 
    } 
} 

}