在 C# 中实现管道 - 使用哪些（流？）类？

发布于 2024-10-09 02:23:59 字数 438 浏览 8 评论 0原文

我很难理解如何在 C# 中使用流。

我计划有一个这种形式的类：

class Pipe {
    public void PutChar(char c) { ... }
    public char GetChar() { ... }
}

其想法是，一个线程将通过其 PutChar() 方法将字符放入此 Pipe 中，然后在其他线程上将使用 GetChar() 获取 Pipe 中的字符。

在 Java 中，我会使用 PipedReader 和 PipedWriter 类。 C# 中似乎没有等效的类，那么我应该在这里使用哪些（流？）类？或者流不是实现这个的正确方法吗？也许我最好使用 Queue 来代替？

谢谢

原文

I am having some hard time understanding how to work with streams in C#.

I plan to have a class of this form:

class Pipe {
    public void PutChar(char c) { ... }
    public char GetChar() { ... }
}

The idea is that one thread will put chars in this Pipe through its PutChar() method, and later on other thread will make use of GetChar() to get the chars that are in Pipe.

In Java I'd make use of PipedReader and PipedWriter classes. There seem to be no equivalent classes in C#, so which (stream?) classes should I use here? Or aren't streams the correct way of implementing this? Maybe I'd be better off using a Queue, instead?

Thanks

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

沩ん囻菔务 2024-10-16 02:23:59

因为您想要跨线程通信，并且您不想使用上面答案中提到的任何 NamedPipes，而不是

1 - 您可以创建生产者消费者队列。

2-如果您使用的是.net 4.0，则可以使用ConcurrentQueue。

回复收藏 0 原文

微凉徒眸意 2024-10-16 02:23:59

在 System.IO.Pipes 命名空间中查找可以流式传输到的类管道。但是，您可能需要考虑使用 WCF ://msdn.microsoft.com/en-us/library/system.servicemodel.netnamedpipebinding.aspx" rel="nofollow">NetNamedPipeBinding 用于在应用程序中实现管道。

回复收藏 0 原文

不必了 2024-10-16 02:23:59

如果您使用 .NET 4.0，请查看 BlockingCollection 和任务并行库。这两者结合在一起创建了一种使用任务跨线程移动数据的好方法。

MSDN 上的示例代码显示了您需要执行的所有操作。

回复收藏 0 原文

小草泠泠 2024-10-16 02:23:59

查看 NamedPipe。另请查看这篇文章。

回复收藏 0 原文

月棠 2024-10-16 02:23:59

StreamReader & StreamWriter 与 PipedReader 和 PipedReader 非常相似。管道作家。如果你声明一个 MemoryStream 来保存缓冲区，你就可以实现它。

下面是一个快速代码示例，它可以满足您的需求。

class Pipe {
    MemoryStream _ms;
    StreamReader _sr;
    StreamWriter _sw;

    public Pipe()
    {
       _ms = new MemoryStream();
       _sr = new StreamReader(_ms);
       _sw = new StreamWriter(_ms);
    }

    public void PutChar(char c) { _sw.Write(c) }
    public char GetChar() { return _sw.Read();  }
}

StreamReader & StreamWriter are very similar to PipedReader & PipedWriter. If you declare a MemoryStream to hold the buffer you can implement it.

A quick code sample is below which may do what you are looking for.

class Pipe {
    MemoryStream _ms;
    StreamReader _sr;
    StreamWriter _sw;

    public Pipe()
    {
       _ms = new MemoryStream();
       _sr = new StreamReader(_ms);
       _sw = new StreamWriter(_ms);
    }

    public void PutChar(char c) { _sw.Write(c) }
    public char GetChar() { return _sw.Read();  }
}

回复收藏 0 原文

~没有更多了~