问题标签 [fifo]

我正在尝试使用命名管道在守护进程和客户端之间设置双向通信。代码在尝试打开用于输入的命名管道时挂起 为什么？

我想通过 2 个单向 FIFO 发送和接收消息

数据流

我需要有边界结构化消息mesg_len+mesg_type+mesg_data

作用是如果用户在stdin上输入“Knock Knock”，它指向客户端，客户端通过FIFO1将此消息发送到服务器，服务器比较字符串，如果匹配到“Knock Knock”，则服务器回复消息“谁在那里？” 通过 FIFO2 到客户端，客户端将此消息写入标准输出。

交互部分如下：

下面是我的代码：

当客户端键入“exit”时，我需要有关 kill() 信号的帮助。调用 kill() 后，客户端进程似乎仍然存在。所以我需要输入 ctrl+c 来结束

请帮我。非常感谢！

我需要一个 python 脚本为文本文件中的行实现循环缓冲区，限制为 N 行，如下所示：

最好的解决方案是什么？

编辑：此脚本应创建和维护仅包含最新 N 行的文本文件。然后它应该弹出推入的第一行。就像一个先进先出缓冲区。

我在一个目录中有一些已排序的 gzip 文件。如何将其中一些组合成另一个已排序的 gzip 文件？现在我正在使用显式fifos。有没有办法在 bash 中做到这一点？我是一个 bash 菜鸟，所以请原谅我缺乏风格。

我正在寻找将其转换为类似...

......但不知道如何。我是否需要一个循环将参数构建为字符串？有什么神奇的捷径吗？也许map gzcat $@？

注意：每个文件都超过 10GB（解压后为 100GB）。我有一个 2TB 驱动器，所以这不是问题。此外，该程序必须在 O(n) 中运行，否则将变得不可行。

我正在使用事件源 rpc 插件在一段时间后从服务器端推送数据，例如。200 毫秒，因此不存在客户端请求，因此我需要在客户端有一个缓冲区（FIFO），因为服务器发送大量数据（200 毫秒非常快）并在客户端图表中显示数据（我正在使用 GChart），我需要在客户端顺利显示它，这就是为什么我需要客户端的缓冲区来保存数据并显示值 (x,y)(x1,y1)(x2,y3)....( Xn,Yn)... 在图中以 FIFO 的方式运行并且运行平稳，并且我可以根据客户端性能动态调整 200ms 延迟并向服务器发送回关于

客户端和服务器之间的通信可以写成人类对话，如下所示

客户：减慢先生服务器我无法处理这么多数据而且我的 FIFO 缓冲区已满..

服务器：好的，我将延迟时间从 200 毫秒更改为 500 毫秒，但是当您要执行的数据较少时，请告诉我，我会再次将其更改为更快的心情，即 200 毫秒。

客户：好的，现在发送我的快速数据，我的缓冲区是空的。

在此先感谢 Gwt、gchart、事件源

如果我有proc1 | proc2办法准确测量流过管道的比特率，而不会改变行为，就好像测量设备不存在一样？像 tee 这样的东西可以吗？我想要proc1 | tee proc2 > flow_measurement_thing还是proc1 | tee flow_measurement_thing > proc2？如果我正确理解管道，默认情况下，unix 管道可以咀嚼 4096 字节，如果接收器读取数据的速度不快，它们会阻塞，所以我担心测量设备本身可能会导致“层流”流过如果我没有正确实施，管道会变得“湍流”。

实际用例在 python 中粘合，带有来自 os 的命名管道 .. 这是一个大大简化的示例

为简单起见，让我们假设转换器不修改比特率，那么我希望能够验证是否capture | convert | /dev/null以与capture | /dev/null

有没有办法用 Go 语言创建一个 unix FIFO？包中没有Mkfifo, 也没有，尽管我预计命名 FIFO 主要用于 posix 操作系统。实际上，有创建未命名的FIFO（管道）的功能，但没有创建命名管道的功能。Mknodos

我是唯一需要它们的人吗？

有没有办法在 shell 中创建非阻塞/异步命名管道或类似的东西？这样程序就可以在其中放置行，这些行将保留在 ram 中，并且当某些程序可以从管道中读取某些行时，将未读取的内容留在 fifo 中？程序也很可能可以同时写入和读取该 fifo。起初我虽然也许这可以使用文件来完成，但在网上搜索了一下之后，似乎没有什么好处可以来自文件同时读取和写入的事实。命名管道几乎可以工作，只是有两个问题：首先，如果另一端没有人，它们会阻塞读/写，其次，即使我让写入阻塞并设置两个进程写入管道，而没有人在读，通过尝试为每个进程写一行，然后尝试head -n 1 <fifo>我只得到了我需要的一行，但是两个写入过程都终止了，第二行丢失了。有什么建议么？

编辑：也许可以使用一些中间程序来帮助解决这个问题，充当作家和读者之间的调解人？

我已经实现了一个 4 FIFO 队列和一个搜索 FIFO 索引的块，当找到一个不为空的 FIFO 将提取数据结束时，它将串行发送。

这是代码：

在您要将数据插入一个未满的队列并且传输正在运行之前，它工作正常。该步骤省略。因此，传输将无法正常工作。我希望它独立工作。

前任 ：

我使用 Altium Designer Winter 09 工作（在 fpga 上模拟和实现）

我正在尝试在 Java 中创建一个优先级阻塞队列，以维护具有相同优先级的元素的 FIFO 顺序。Oracle 文档对此提供了一些帮助，但我仍然很纠结。

我应该注意到以下主题对我来说都是非常新的：泛型、作为类型的接口和静态嵌套类。所有这些都在以下类定义中发挥作用。尤其是泛型，令人困惑，我敢肯定我在这里完全搞砸了。

我已包含注释以识别我当前遇到的编译器错误。

几个具体问题：

1. 可以让类代表排队的事件对象，而实际的队列是静态类成员吗？

2. 将 Oracle 的 FIFO 事件“包装器”作为静态嵌套类包含在内是否合理？

3. 我至少在正确的轨道上，在一个外部班级做这一切吗？

这是我写的课程：