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 构造，该团队已经在博客中介绍了几种方法来做到这一点，here is one。