c# - 是否有不使用 OS 管道的类似管道的 .NET Stream 类？

Question

使用 C#/.NET(实际上是 Xamarin/Mono)。

我有一个类，其方法 (A) 接受它写入的流， 我还有另一个类，其方法 (B) 接受要读取的流。

我想要一个同时传递给 (A) 和 (B) 的流，这样当 (A) 写入流，数据可以被 (B) 读取。

已经有这样一个不使用 OS 管道的野兽了吗？

Answer 1

我会用BlockingCollection .例如

BlockingCollection<int> bc = new BlockingCollection<int>();
Task.Run(() => new Reader(bc).DoWork());
Task.Run(() => new Writer(bc).DoWork());

---

public class Reader
{
    BlockingCollection<int> _Pipe = null;
    public Reader(BlockingCollection<int> pipe)
    {
        _Pipe = pipe;
    }

    public void DoWork()
    {
        foreach(var i in _Pipe.GetConsumingEnumerable())
        {
            Console.WriteLine(i);
        }
        Console.WriteLine("END");
    }
}

public class Writer
{
    BlockingCollection<int> _Pipe = null;
    public Writer(BlockingCollection<int> pipe)
    {
        _Pipe = pipe;
    }

    public void DoWork()
    {
        for (int i = 0; i < 50; i++)
        {
            _Pipe.Add(i);
            Thread.Sleep(100);
        }
        _Pipe.CompleteAdding();
    }
}