fifo

    0热度

    2回答

    我想创建一个服务器进程和一个客户端进程 - 用于可选的类分配 - 并使它们相互通信。这位教授告诉我们: 1)我们必须使用O_NONBLOCK 2)我们必须创建2个FIFO,一个仅用于阅读和一个只写 3)我们不能使用套接字 所以,我在服务器进程中创建了2个FIFO,我试图打开它们,但是打开WRONLY返回“没有这样的设备或地址”。 服务器进程: ...... if(mkfifo("fifo1",

    0热度

    1回答

    我想调试我写的一个更大的程序,我提取了其中一个线程,基本上是向一个fifo写入了一个24值的数组,另一端是另一个应该读取的线程数据只在全部写完之后。 Transmit.h #include "stdafx.h" #include <iostream> SC_MODULE(Transmit){ sc_inout <bool> ServerTx; sc_fifo_out<int

    0热度

    1回答

    是否有可能实例化多个模块以从同一个FIFO读取,假设它们不是在同一时间读取,而是轮流? 例如: int _tmain(int argc, _TCHAR* argv[]) { sc_fifo<int> PacketTx(24); sc_fifo<int> PacketRx(20); Transmit t1("Transmit"); t1.PacketRx(

    0热度

    2回答

    我正在尝试编写两个程序,这两个程序将通过FIFO在C中进行通信。我正在尝试使用FIFO来分配我的作业。 当我知道消息的数量并用for循环读取它时,它会打印出从另一端发送的所有消息。如果我使用while循环,它只发送其中两个。代码稍微偏离了这个问题改变了How to send a simple string between two programs using pipes? 这工作: /* writ

    1热度

    1回答

    SQS FIFO TPS限制从AWS SQS文档FIFO queues它说: FIFO队列还提供一次准确处理但被限制为每秒300个交易(TPS)。 ... FIFO队列支持邮件组,允许单个队列中的多个有序消息组。属于同一消息组 ... 消息总是处理一个接一个,严格相对于所述消息组(但是,消息的顺序属于不同的消息组中可能无序处理)。 是否知道这是否意味着将300 TPS限制应用于while队列或每个

    0热度

    2回答

    我目前正在学习C语言的多线程,但有一点我不太明白,我们的命名管道excersize。 我们期望做一个文件搜索系统的实现,该文件搜索系统可以找到文件并用一个进程添加到缓冲区,第二个进程应该从第一个进程的线程获取文件名,在该文件中找到搜索查询并返回第一个位置通过管道加工。我做了几乎所有的事情,但我很困惑如何做两个进程之间的沟通。 这里是我的代码,做通信: 的main.c void *controlle

    0热度

    2回答

    在我们的项目中,我需要将消息推送到ActiveMQ并保持它们的持久性。当我发送新消息并且内存限制超过队列中最老的消息时,应该从队列中删除/删除或替换为新消息。 我不想清除整个队列,队列就像我们产品的故障安全消息积压一样工作,所以我需要在队列中保留最后x个消息量。 我试图从谷歌和目前没有运气看。 这里是我的settings.xml政策 <destinationPolicy> <polic

    0热度

    1回答

    我想用fifo算法开发缓存模拟器。我了解fifo算法的工作原理,但是我在理解如何实现它时遇到了问题。我提供了用于开发缓存的模板。我想知道实现算法的好方法。 #include <stdlib.h> extern int opt_assoc, opt_block, opt_capacity, opt_repl, opt_verbose; typedef struct { int se

    0热度

    1回答

    我对管道有用户读/写权限。小组已阅读。其他已阅读。但是当我运行它时,程序会“卡住”。计划1是“父母”。计划2是“孩子”。 计划1: int main(int argc, char * argv[]) { FILE *fptr; //for opening and closing input file int fdw;// write to pipe; int fdr; //read to

    0热度

    1回答

    Im声明sc_fifo为sc_fifo_out <int> PacketTx;并且Im试图使用SC_THREAD将20个样本写入此fifo。我在另一个SC_THREAD阅读了fifo的内容。我的问题是我需要在FIFO中写入20个值,然后我才从FIFO中读取任何内容,所以我使用sc_signal来维护这个属性。 下面是一个简化的例子: Transmit.h SC_MODULE(Transmit){