同时运行两个任务

Question

嗨，我有一个 winform 应用程序，它由 25 个文本框组成，这些文本框代表实时接收的值，而它们下方有标签，显示这些值的最小值和最大值flow in shown with red arrows

现在，当应用程序启动时，它会在每个文本框及其标签中填充数据，延迟为 1 秒。因此，它需要 7 到 8 秒才能完全填充数据。

我想要的是将填充文本框和标签的任务分成两部分。

我尝试了多线程，但它不适合我

到目前为止我的代码

        Thread mmathread;
        while (start)
        {
            try
            {
                RPM_TEXT.Text = ReadRPM().ToString() + " rpm";
                mmathread = new Thread(() => mma(rpm_list, ReadRPM(), RPM_mma));
                mmathread.Start();
                
            }
            catch { }

            try { EL_TEXT.Text = ReadEngineLoad().ToString() + " %";
                mmathread = new Thread(() => mma(el_list, ReadEngineLoad(), EL_mma));
                mmathread.Start();
                
            }
            catch { }
            try { ECT_TEXT.Text = ReadCoolantTemp().ToString() + " °C";
                mmathread = new Thread(() => mma(ect_list, ReadCoolantTemp(), ECT_mma));
                mmathread.Start();
                }
            catch { }
            }

函数定义为

private void mma(List<int> parameter_list, int parameter, Label label)
            {
            if (parameter_list.Count == 9) { parameter_list.Add(parameter); 
            parameter_list.RemoveAt(0); }
            else { parameter_list.Add(parameter); }
            minpara = parameter_list.Min();
            maxpara = parameter_list.Max();
            avrgpara = parameter_list.Sum() / parameter_list.Count;

            label.Text = $"Min = {minpara}, Avg = {avrgpara}, Max = {maxpara}";
            }

如果我直接调用该函数，它会更新标签，但如果我向它添加线程，则标签不会填充

Answer 1

使用线程时，您需要在标签上使用 Invoke。像这样

 label.Invoke((MethodInvoker) delegate () {label.Text = $"Min = {minpara}, Avg = {avrgpara}, Max = {maxpara}"};

https://docs.microsoft.com/en-us/dotnet/api/system.windows.forms.control.invoke?view=net-5.0

Answer 2

您可以使用Task<T>s 代替Threads¹。 Task.Run 方法将提供的操作卸载到ThreadPool，稍后可以通过Task<T> 的Result 属性获得操作的结果。您可以awaitTask<T>s，以便在后台运行操作时 UI 将保持响应。您还可以一次启动多个任务，以便并行调用这些操作。在这种情况下，您可以使用Task.WhenAll 方法await 所有并行任务。示例：

while (start)
{
    Task delayTask = Task.Delay(TimeSpan.FromSeconds(1));
    Task<string> task1 = Task.Run(() => ReadRPM());
    Task<string> task2 = Task.Run(() => ReadEngineLoad());
    Task<string> task3 = Task.Run(() => ReadCoolantTemp());
    await Task.WhenAll(task1, task2, task3);
    RPM_TEXT.Text = task1.Result;
    EL_TEXT.Text = task2.Result;
    ECT_TEXT.Text = task3.Result;
    await delayTask;
}

在此示例中，我添加了一个 Task.Delay 任务，以将最大频率设置为每秒一个循环。

此代码必须放在具有async 修饰符的方法（或事件处理程序）中，以启用await 运算符。

¹ _{我指的是Thread 类，而不是thread as a concept。}

Answer 3

详细说明@BojanB 的答案，您可以使用传统的WinForms InvokeRequired/Invoke 模式。如果在非 UI 线程上评估 InvokeRequired 属性，则返回 true。如果需要Invoke 调用，那么您只需Invoke 相同的调用（将调用编组到 UI 线程上）就可以完成。如果您这样做，则可以从 UI 线程或任何其他线程调用相同的函数。

首先我创建了这三个辅助函数：

private void SetTextBoxFromThread(TextBox textBox, string contents)
{
    if (InvokeRequired)
    {
        Invoke(new Action<TextBox, string>(SetTextBoxFromThread), new object[] { textBox, contents });
        return;
    }

    textBox.Text = contents;
}

private string ReadTextBoxFromThread(TextBox textBox)
{
    if (InvokeRequired)
    {
        return (string)Invoke(new Func<TextBox, string>(ReadTextBoxFromThread), new[] { textBox });
    }

    return textBox.Text;
}
private void SetLabelFromThread(Label label, string contents)
{
    if (InvokeRequired)
    {
        Invoke(new Action<Label, string>(SetLabelFromThread), new object[] { label, contents });
        return;
    }

    label.Text = contents;
}

有了这些，我使用这个愚蠢的小线程函数（匹配 ThreadStart 委托的 async 版本）对它们进行了测试：

private int isPaused = 0;       //used like a bool, int for clear atomicity

private async void ThreadFunc()
{
    while (isPaused == 0)
    {
        var now = DateTime.Now;
        var str1 = now.ToString("T");
        var str2 = now.ToString("t");
        var str3 = now.ToString("s");

        SetTextBoxFromThread(textBox1, str1);
        SetTextBoxFromThread(textBox2, str2);
        SetTextBoxFromThread(textBox3, str3);

        await Task.Delay(1500);

        SetLabelFromThread(label1, ReadTextBoxFromThread(textBox1));
        SetLabelFromThread(label2, ReadTextBoxFromThread(textBox2));
        SetLabelFromThread(label3, ReadTextBoxFromThread(textBox3));
    }
}