返回兩個長時間運行的方法的值，使用線程

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

}