如何在不阻塞 GUI 的情况下等待线程完成

本文关键字:等待 情况下 线程 GUI | 更新日期: 2023-09-27 18:35:56

>我有 2863 个对象的数组。我希望每 1000 个对象通过 4 个线程(运行 PC # 的 CPU)读取数组数据进行两次"运行"。

目前,我的源代码正在对数据进行分区以更正线程数和运行次数:

单次运行大小(默认)= 1000 个元素
运行次数 = 2
额外线程运行大小 = 866 个元素
开始运行 [1/2]
Thread as readDCMTags(i=0,firstIndex=0, lastIndex=249
Thread as readDCMTags(i=1,firstIndex=250, lastIndex=499
Thread as readDCMTags(i=2,firstIndex=500, lastIndex=749
Thread as readDCMTags(i=3,firstIndex=750, lastIndex=999
开始运行 [2/2]
Thread as readDCMTags(i=0,firstIndex=1000, lastIndex=1249
Thread as readDCMTags(i=1,firstIndex=1250, lastIndex=1499
Thread as readDCMTags(i=2,firstIndex=1500, lastIndex=1749
Thread as readDCMTags(i=3,firstIndex=1750, lastIndex=1999
Extra Thread as readDCMTags(i=1,firstIndex=2000, lastIndex=2865

但是,当前的源代码正在一次启动所有线程,它不会等待运行结束。当我从当前运行中加入线程时,GUI 正在挂起。如何解决问题?

源代码是:

nrOfChunks = 2866 / 1000;
int leftOverChunk = 2866  % 1000;
for(int z = 0; z < nrOfChunks; z++)
{
    addToStatusPanel("'nStarting run [" + (z+1).ToString() + " / " + nrOfChunks.ToString() + "]");
    int indexesPerThread = 1000 / 5; #nrOfThreads
    int leftOverIndexes = 1000 % 5; #nrOfThreads
    threads = new Thread[nrOfThreads];
    threadProgress = new int[nrOfThreads];
    threadDCMRead = new int[nrOfThreads];
    for(int i = 0; i < nrOfThreads; i++)
    {
        int firstIndex = (i * indexesPerThread+z*Convert.ToInt32(chunkSizeTextBox.Text));
        int lastIndex = firstIndex + indexesPerThread - 1;
        if(i == (nrOfThreads- 1))
        {
            if(i == (nrOfThreads - 1))
            {
                lastIndex += leftOverIndexes;
            }
        }
        addToStatusPanel("readDCMTags(i=" + i.ToString() + ",firstIndex=" + firstIndex.ToString() + ", lastIndex=" + lastIndex.ToString());
        threads[i] = new Thread(() => readDCMTags(i.ToString(), firstIndex, lastIndex));
        threads[i].Name = i.ToString();
       threads[i].Start();
    }
    if(z == (nrOfChunks - 1))
    {
        int firstIndex = (nrOfChunks * Convert.ToInt32(chunkSizeTextBox.Text));
        int lastIndex = firstIndex + leftOverChunk - 1;
        addToStatusPanel("readDCMTags(i=" + z.ToString() + ",firstIndex=" + firstIndex.ToString() + ", lastIndex=" + lastIndex.ToString());
    }
}

在循环for(int i = 0; i < nrOfThreads; i++)线程数组的 join 命令之后添加,然后进行下一次运行循环for(int z = 0; z < nrOfChunks; z++)挂起 GUI。

如何在不阻塞 GUI 的情况下等待线程完成

根据定义,如果您等待,则会阻塞(当前正在执行的线程会阻止等待其他内容)。

相反,你想要的是当所有线程都完成时发生一些事情。也就是说,"所有线程都已完成"是一个事件。因此,最好的选择是在后台线程中等待,并在所有线程完成时触发事件。

如果 GUI 对此感兴趣,则 GUI 线程将需要订阅该特定事件。

编辑:伪代码(未测试,只是想法)。

waitBg = new Thread(() => 
  {
    foreach (thread in threads)
      thread.WaitFor();
     // All threads have finished
     if (allThreadFinishedEvent != null)
        allThreadFinishedEvent();
  }
);

然后,在 allThreadFinishEvent 的处理程序上,您可以执行任何您想做的事情(如果您想更改 UI 中的某些内容,请记住将其调度到主线程,因为这将在 bg 线程上下文中执行)。

如何将此线程逻辑放在后台工作线程中,并将后台工作进程的结果发送回接口。这样,在程序处理线程时,您的接口不会被锁定。

您可以在此处找到初始化和使用后台工作线程的 MSDN 示例。

我认为这应该是正确的前进道路。