如何从 3 个线程写入文本框？ [复制]

Question

我有 3 个线程执行不同的工作，我需要收集有关它们的日志并将其写入文本框。所以我有：

public delegate void Notify(string message);

这些线程的 3 个类中的每一个都有：

public event Data.Notify Notify;

（数据只是一个静态类，我在其中保存我的应用程序的一般信息）。 在我使用的所有这 3 个类中的方法 Work() 中：

Notify?.Invoke("message");

在消息中，我知道作业是否已启动，是否成功。在我得到的表格类中：

Data.workingThread.Notify += Thread_Notify;
Data.readingThread.Notify += Thread_Notify;
Data.writingThread.Notify += Thread_Notify;
Data.writingThread.Start();
Data.workingThread.Start();
Data.readingThread.Start();

Thread_Notify 在哪里：

private void Thread_Notify(string message)
{
    tbLogs.Text += message;
}

当我运行代码时，它抛出 System.InvalidOperationException，因为我尝试访问 'tbLogs' 而不是从创建它的线程。 我为此方法和 lock(tbLogs) 尝试了 async/await，但这些对我不起作用

Answer 1

据我所知，只有在主窗口线程中才能直接管理文本框。 由于您的事件（Thread_Notify）可以从其他线程调用，因此您不能直接使用它，因为如果它在与主窗口不同的线程中运行，则会抛出异常。

为了让它工作，你必须这样写通知：

private void Thread_Notify(string message)
{
   Dispatcher.Invoke(new Action(() =>
   {
      tbLogs.Text += message;
   }), DispatcherPriority.Background);
}

Answer 2

看看Control.InvokeRequiredproperty 和Invokemethod。

使用它们在 UI 线程上调度文本框更改。

例子：

public partial class Form1 : Form
{
    public Form1()
    {
        InitializeComponent();
        Random rnd = new Random();
        Action GetAction(string threadName) => () =>
        {
            for (int i = 0; i < 5; i++)
            {
                var tid = Thread.CurrentThread.ManagedThreadId;
                Thread_Notify($"{threadName} ({tid}): {i} ");
                int sleepMillis = 0;
                lock (rnd) sleepMillis = rnd.Next(0, 400);
                Thread.Sleep(sleepMillis);
            }
        };

        Task.WhenAll(
            Task.Run(GetAction("worker1")),
            Task.Run(GetAction("worker2")),
            Task.Run(GetAction("worker3"))
        ).ContinueWith(_ => Thread_Notify("Done."));
    }
    private void Thread_Notify(string message)
    {
        Action setText = delegate { tbLogs.Text += message + "\r\n"; };
        if (tbLogs.InvokeRequired)
        {
            tbLogs.Invoke(setText);
        }
        else
        {
            setText();
        }
    }
}

另一种选择是使用System.Reactive.Linq 库为您进行调度：

1. 创建主题。
2. 在工作线程中调用_subject.OnNext(message)。
3. 更改订阅中的文本框。

例子：

using System.Reactive.Linq;
using System.Reactive.Subjects;
// ...
public partial class Form1 : Form
{
    private readonly Subject<string> _messages = new Subject<string>();
    public Form1()
    {
        InitializeComponent();
        Random rnd = new Random();
        Action GetAction(string threadName) => () =>
        {
            for (int i = 0; i < 5; i++)
            {
                var tid = Thread.CurrentThread.ManagedThreadId;
                _messages.OnNext($"{threadName} ({tid}): {i} ");
                int sleepMillis = 0;
                lock (rnd) sleepMillis = rnd.Next(0, 400);
                Thread.Sleep(sleepMillis);
            }
        };

        Task.WhenAll(
            Task.Run(GetAction("worker1")),
            Task.Run(GetAction("worker2")),
            Task.Run(GetAction("worker3"))
        ).ContinueWith(_ => _messages.OnNext("Done."));

        _messages
            .ObserveOn(this)
            .Subscribe(msg => tbLogs.AppendText(msg + "\r\n"));
    }
}