C# 可以并行 foreach while 循环吗？

Question

我不确定 Parallel.foreach 的内部线程处理如何工作以及它是否可以保证这样的构造能够工作？

Parallel.Foreach(Connections, c =>
    {
        Input in = c.getInput();
        while (in.hasNext()) {
            object o = in.getNext();
            dosomething(o);
        }
    }
);

其中 in.hasNext() 只是等待输入流中的对象并返回 true。基本上我可以在并行 foreach 结构中运行一堆无限 while 循环，同时保证它们全部同时运行。

（对于勇敢的人来说，我可以调整它，以便我可以通过添加（和删除，这应该是微不足道的）连接来编辑连接列表，并且它仍然会从列表中的所有连接读取输入）。

Answer 1

1. 使用它的线程数量是有限的，因此某些元素将被陆续处理。

2. 在枚举时编辑列表并不好。您可能会遇到异常（取决于您正在使用的列表）

3. 为什么不开始一个新的列表）每个连接有一个线程？

示例代码：

public ConnectionOpen(data)  
{  
    Connection conn=new ...  
    lock(Connections)  
    {  
         Connections.Add(conn);  
    }  

    new Thread(()=>  
    {  
        Receive(conn);//infinite loop goes here  
    }).Start();  
}  

public ConnectionClose(conn)  
{  
    bool removed=false;  
    lock(Connections)  
    {  
        removed=Connections.Remove(conn);  
    }  
    if(removed) conn.StopReceiving();  
}  

Answer 2

基本上，我可以在并行 foreach 结构中运行一堆无限 while 循环，同时保证它们全部同时运行

？不。只有有限数量的工作线程会同时启动，所以如果您运行的无限循环多于实际数量线程，最后一个永远不会运行......

Answer 3

从技术上讲，这段代码可以工作，但“同时”运行的线程的精确数量会有所不同。

除了并行扩展之外，.NET 4 还向线程池添加了“爬山”和线程注入，因此基本上 .NET 线程池会尝试将线程添加到 Parallel.ForEach 循环中，以查看是否有更多线程完成，因为您的线程池永远不会完成线程的数量会有所不同，但我猜这将是不理想的。

您可以尝试使用 ParallelWhile 构造，该团队已在博客中介绍了几种执行此操作的方法，这是一个。