如何強制主GUI線程在更新後從其他線程更新列表框？

Question

我在使用生產者/消費者隊列結構的多線程下載器上修修補補;下載部分工作正常，但我遇到了一個問題，保持GUI更新。

現在我使用窗體上的列表框控件來顯示狀態消息和下載進度的更新，最終我希望用progressbar來替換它。

首先將Form1代碼放在後面;該表格包含只是一個按鈕，列表框：

public partial class Form1 : Form 
{ 
    public Form1() 
    { 
     InitializeComponent(); 
    } 

    public void SetProgressMessage(string message) 
    { 
     if (listboxProgressMessages.InvokeRequired) 
     { 
      listboxProgressMessages.Invoke(new MethodInvoker(delegate() 
      { SetProgressMessage(message); })); 
     } 
     else 
     { 
      listboxProgressMessages.Items.Add(message); 
      listboxProgressMessages.Update(); 
     } 
    } 

    private void buttonDownload_Click(object sender, EventArgs e) 
    { 
     SetProgressMessage("Enqueueing tasks"); 
     using (TaskQueue q = new TaskQueue(4)) 
     { 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
      q.EnqueueTask("url"); 
     } 
     SetProgressMessage("All done!"); 
    } 
} 

現在生產者/消費者邏輯。消費者一點一點地下載文件，並且應該告訴居住在GUI線程上的列表框如何進展;這是有效的，但是在完成所有操作之前，列表框並沒有實際更新，還有消息出現在「全部完成」之後。消息，這是不可取的。

TaskQueue.cs：

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 
using System.Threading; 
using System.IO; 
using System.Net; 
using System.Windows.Forms; 
using System.Runtime.Remoting.Messaging; 

namespace WinformProducerConsumer 
{ 
    public class TaskQueue : IDisposable 
    { 
     object queuelocker = new object(); 
     Thread[] workers; 
     Queue<string> taskQ = new Queue<string>(); 

    public TaskQueue(int workerCount) 
    { 
     workers = new Thread[workerCount]; 
     for (int i = 0; i < workerCount; i++) 
      (workers[i] = new Thread(Consume)).Start(); 
    } 

    public void Dispose() 
    { 
     foreach (Thread worker in workers) EnqueueTask(null); 
     foreach (Thread worker in workers) worker.Join(); 
    } 

    public void EnqueueTask(string task) 
    { 
     lock (queuelocker) 
     { 
      taskQ.Enqueue(task); 
      Monitor.PulseAll(queuelocker); 
     } 
    } 

    void Consume() 
    { 
     while (true) 
     { 
      string task; 
      Random random = new Random(1); 
      lock (queuelocker) 
      { 
       while (taskQ.Count == 0) Monitor.Wait(queuelocker); 
       task = taskQ.Dequeue(); 
      } 
      if (task == null) return; 

      try 
      { 
       Uri url = new Uri(task); 
       HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url); 
       HttpWebResponse response = (HttpWebResponse)request.GetResponse(); 
       response.Close(); 
       Int64 iSize = response.ContentLength; 
       Int64 iRunningByteTotal = 0; 

       using (WebClient client = new System.Net.WebClient()) 
       { 
        using (Stream streamRemote = client.OpenRead(new Uri(task))) 
        { 
         using (Stream streamLocal = new FileStream(@"images\" + Path.GetFileName(task), FileMode.Create, FileAccess.Write, FileShare.None)) 
         { 
          int iByteSize = 0; 
          byte[] byteBuffer = new byte[iSize]; 
          while ((iByteSize = streamRemote.Read(byteBuffer, 0, byteBuffer.Length)) > 0) 
          { 
           streamLocal.Write(byteBuffer, 0, iByteSize); 
           iRunningByteTotal += iByteSize; 

           double dIndex = (double)iRunningByteTotal; 
           double dTotal = (double)byteBuffer.Length; 
           double dProgressPercentage = (dIndex/dTotal); 
           int iProgressPercentage = (int)(dProgressPercentage * 100); 

           string message = String.Format("Thread: {0} Done: {1}% File: {2}", 
            Thread.CurrentThread.ManagedThreadId, 
            iProgressPercentage, 
            task); 

           Form1 frm1 = (Form1)FindOpenForm(typeof(Form1)); 
           frm1.BeginInvoke(new MethodInvoker(delegate() 
           { 
            frm1.SetProgressMessage(message); 
           })); 
          } 
          streamLocal.Close(); 
         } 
         streamRemote.Close(); 
        } 
       } 

      } 
      catch (Exception ex) 
      { 
       // Generate message for user 
      } 
     } 
    } 

    private static Form FindOpenForm(Type typ) 
    { 
     for (int i1 = 0; i1 < Application.OpenForms.Count; i1++) 
     { 
      if (!Application.OpenForms[i1].IsDisposed && (Application.OpenForms[i1].GetType() == typ)) 
      { 
       return Application.OpenForms[i1]; 
      } 
     } 
     return null; 
    } 
} 

}

任何建議，例子嗎？我四處尋找解決方案，但找不到任何我可以遵循或工作的東西。 。

更換frm1.BeginInvoke（新MethodInvoker（委託（）與frm1.Invoke（新MethodInvoker（委託（）死鎖結果，我願意在這裏難倒

來源： 生產者/消費者例如：http://www.albahari.com/threading/part4.aspx

更新：我以錯誤的方式解決問題;而不是從工作線程調回GUI，我將使用GUI線程必須留意的事件。經驗教訓:)

Answer 1

你應該消除FindOpenForm和ProgressChanged事件添加到TaskQueue。它是絕對不是 TaskQueue責任直接調用表示層（窗體或控件）。這是形式的責任，聽取任務產生的「進度變更」事件，然後更新自己的財產。

這將很容易解決您的問題，它會保持簡單，遵循最佳實踐並消除時間問題，線程問題等。

• MSDN搜索籌款活動在http://social.msdn.microsoft.com/Search/en-US?query=raising+events&ac=8

• 事件教程（C＃）在http://msdn.microsoft.com/en-us/library/aa645739(VS.71).aspx

• 引發事件和http://msdn.microsoft.com/en-us/library/ms973905.aspx響應事件（VB.NET）

• [必讀] BackgroundWorker組件概述在http://msdn.microsoft.com/en-us/library/8xs8549b.aspx說明您需要用TaskQueue事件和表單處理這些事件來完成。

Answer 2

我的另一個更適合。一旦您更改TaskQueue以提升ProgressChanged事件，此答案更合適。

---

嘗試撥打listboxProgressMessages.Refresh()。這迫使油漆。檢查Control.Refresh文檔。有時候，你必須調用表單的刷新方法。

Control.Refresh方法

強制控制無效的 客戶區域並立即重繪 自己和任何子控件。

http://msdn.microsoft.com/en-us/library/system.windows.forms.control.refresh.aspx

Answer 3

在你的代碼

此外，而不是調用BeginInvoke，叫Invoke - 後者是從調用者同步。這意味着你需要通過GUI調用並等待GUI返回之前完成其操作。

此外，GUI線程可能會餓死，我認爲調用到GUI線程的控件實際上是編組到消息泵 - 如果泵不泵，那麼調用永遠不會通過。可以使用BackgroundWorker表單組件。這已經被構建爲在WinForms中工作，從而與GUI一起工作。它公開了一個ProgressChanged事件，您可以使用該事件將任意進度報告傳遞迴UI。事件本身被編組，以便自動調用GUI線程。這消除了您手動執行此操作的需要。

BackgroundWorker線程也使用線程池。