为什么这个 Parallel.ForEach 代码会冻结程序？

Question

更多新手问题：

这段代码从主窗口的列表中抓取了一些代理（我不知道如何使变量在不同的函数之间可用）并检查每个代理（简单的httpwebrequest）然后添加将它们添加到一个名为 finishedProxies 的列表中。

由于某种原因，当我按下开始按钮时，整个程序挂断了。我的印象是 Parallel 会为每个操作创建单独的线程，让 UI 线程保持独立以便响应？

private void start_Click(object sender, RoutedEventArgs e)
        {
            // Populate a list of proxies
            List<string> proxies = new List<string>();
            List<string> finishedProxies = new List<string>();

            foreach (string proxy in proxiesList.Items)
            {
                proxies.Add(proxy);
            }

            Parallel.ForEach<string>(proxies, (i) =>
            {
                string checkResult;
                checkResult = checkProxy(i);

                finishedProxies.Add(checkResult);
                // update ui
                /*
                 status.Dispatcher.Invoke(
                  System.Windows.Threading.DispatcherPriority.Normal,
                  new Action(
                    delegate()
                    {
                        status.Content = "hello" + checkResult;
                    }
                )); */
                // update ui finished

                
                //Console.WriteLine("[{0}] F({1}) = {2}", Thread.CurrentThread.Name, i, CalculateFibonacciNumber(i));
            });

            
        }

我尝试使用被注释掉的代码来更改Parallel.Foreach 内的 UI，它会在按下开始按钮后使程序冻结。它以前对我有用，但我使用了 Thread 类。

如何从 Parallel.Foreach 内部更新 UI 以及如何使 Parallel.Foreach 工作，以免 UI 在工作时冻结？

Here's the whole code.

Answer 1

您不得在 UI 线程中启动并行处理。请参阅this page 中“避免在 UI 线程上执行并行循环”标题下的示例。

更新： 或者，您可以简单地手动创建一个新线程并在其中开始处理，正如我看到的那样。这也没什么不好。

此外，正如 Jim Mischel 所指出的，您同时从多个线程访问列表，因此存在竞争条件。要么用 ConcurrentBag 替换 List，要么在每次访问列表时将列表包装在 lock 语句中。

Answer 2

避免使用Parallel语句时无法写入UI线程的问题的一个好方法是使用Task Factory和delegate，参见下面的代码，我用它来迭代一个系列中的一系列文件目录，并在Parallel.ForEach 循环中处理它们，在处理完每个文件后，UI 线程会发出信号并更新：

var files = GetFiles(directoryToScan);

tokenSource = new CancellationTokenSource();
CancellationToken ct = tokenSource.Token;

Task task = Task.Factory.StartNew(delegate
{
    // Were we already canceled?
    ct.ThrowIfCancellationRequested();

    Parallel.ForEach(files, currentFile =>
    {
        // Poll on this property if you have to do 
        // other cleanup before throwing. 
        if (ct.IsCancellationRequested)
        {
            // Clean up here, then...
            ct.ThrowIfCancellationRequested();
        }

        ProcessFile(directoryToScan, currentFile, directoryToOutput);

        // Update calling thread's UI
        BeginInvoke((Action)(() =>
        {
            WriteProgress(currentFile);
        }));
    });
}, tokenSource.Token); // Pass same token to StartNew.

task.ContinueWith((t) =>
        BeginInvoke((Action)(() =>
        {
            SignalCompletion(sw);
        }))
);

以及执行实际 UI 更改的方法：

void WriteProgress(string fileName)
{
    progressBar.Visible = true;
    lblResizeProgressAmount.Visible = true;
    lblResizeProgress.Visible = true;

    progressBar.Value += 1;
    Interlocked.Increment(ref counter);
    lblResizeProgressAmount.Text = counter.ToString();
        
    ListViewItem lvi = new ListViewItem(fileName);
    listView1.Items.Add(lvi);
    listView1.FullRowSelect = true;
}

private void SignalCompletion(Stopwatch sw)
{
    sw.Stop();
        
    if (tokenSource.IsCancellationRequested)
    {
        InitializeFields();
        lblFinished.Visible = true;
        lblFinished.Text = String.Format("Processing was cancelled after {0}", sw.Elapsed.ToString());
    }
    else
    {
        lblFinished.Visible = true;
        if (counter > 0)
        {
            lblFinished.Text = String.Format("Resized {0} images in {1}", counter, sw.Elapsed.ToString());
        }
        else
        {
            lblFinished.Text = "Nothing to resize";
        }
    }
}

希望这会有所帮助！

Answer 3

如果有人好奇，我想通了，但我不确定这是否是好的编程或任何解决问题的方法。

我像这样创建了一个新线程：

Thread t = new Thread(do_checks);
t.Start();

并把所有并行的东西放在 do_checks() 中。

看起来还不错。

Answer 4

您的代码的一个问题是您同时从多个线程调用FinishedProxies.Add。这会导致问题，因为List<T> 不是线程安全的。您需要使用锁或其他同步原语来保护它，或者使用并发集合。

这是否会导致 UI 锁定，我不知道。没有更多信息，很难说。如果proxies 列表很长并且checkProxy 执行时间不长，那么您的任务将全部排在Invoke 调用后面。这将导致一大堆待处理的 UI 更新。这将锁定 UI，因为 UI 线程正忙于为那些排队的请求提供服务。

Answer 5

这就是我认为您的代码库中可能发生的事情。

正常场景：您点击按钮。不要使用Parallel.Foreach 循环。使用 Dispatcher 类并推送代码以在后台的单独线程上运行。一旦后台线程完成处理，它将调用主 UI 线程来更新 UI。在这种情况下，后台线程（通过 Dispatcher 调用）知道主 UI 线程，它需要回调。或者简单地说主 UI 线程有自己的身份。

使用 Parallel.Foreach 循环：一旦调用 Paralle.Foreach 循环，框架就会使用 threadpool 线程。 ThreadPool 线程是随机选择的，执行代码不应该对所选线程的身份做出任何假设。在原始代码中，通过Parallel.Foreach 循环调用的调度程序线程很可能无法找出与之关联的线程。当您使用显式线程时，它可以正常工作，因为显式线程有自己的身份，可以被执行代码依赖。

理想情况下，如果您主要关心的是保持 UI 响应，那么您应该首先使用 Dispatcher 类在后台线程中推送代码，然后在其中使用您想要加速整体执行的任何逻辑。

Answer 6

如果您想在 GUI 控件中使用 parallel foreach，例如按钮单击等 然后将并行 foreach 放入 Task.Factory.StartNew 喜欢

private void start_Click(object sender, EventArgs e)
        {
                await Task.Factory.StartNew(() =>
                     Parallel.ForEach(YourArrayList, (ArraySingleValue) =>
                     {

                Console.WriteLine("your background process code goes here for:"+ArraySingleValue);
                     })
                    );
    }//func end

它将解决冻结/卡住或挂起问题