是否可以使用epoll将fifo/pipe数据写入一个线程中的多个读取器？
是的，可以使用epoll将fifo/pipe数据写入一个线程中的多个读取器。
epoll是Linux内核提供的一种高效的I/O事件通知机制，它可以监视多个文件描述符上的事件，并在事件发生时通知应用程序。通过使用epoll，可以实现在一个线程中同时处理多个读取器。
在使用epoll进行fifo/pipe数据写入时，可以将写入操作封装在一个线程中，然后使用epoll监视多个读取器的文件描述符。当有数据可写入时，epoll会通知应用程序，然后应用程序可以将数据写入到相应的读取器中。
这种方式的优势在于可以实现高效的数据传输，避免了多线程之间的竞争和同步问题。同时，通过使用epoll，可以减少线程的数量，提高系统的性能和资源利用率。
在实际应用中，可以使用腾讯云的云服务器（CVM）作为运行环境，使用腾讯云的云原生产品进行部署和管理。具体推荐的产品包括腾讯云云原生容器服务（TKE）和腾讯云容器镜像服务（TCR）。腾讯云云原生容器服务（TKE）是一种高度可扩展的容器管理服务，可以帮助用户快速构建、部署和管理容器化应用。腾讯云容器镜像服务（TCR）则提供了高效、安全的容器镜像仓库服务，可以方便地存储和管理容器镜像。
更多关于腾讯云云原生产品的信息和介绍，可以参考以下链接：
相关·内容
2回答
我正在为单个进程创建三个FIFO管道，其中多个写入线程写入单个读取器线程。目标是为每个写入线程创建一个单独的文件描述符，并为每个写入器文件描述符提供相应的读取器文件描述符，以便我知道哪个写入线程属于每个记录。我在一个循环中调用NASM中的C程序，每个编写<e
浏览 9提问于2020-05-31得票数 0
在我的程序中，有一个发布者，它通过许多不同的fifos/管道将数据写入到其他客户端。我知道如果我打开一个带非阻塞标志的先进先出写，打开将返回一个No such address or device错误。 如果我删除了非阻塞标志，打开将被阻塞，因此只能使用一个管道。这是一个相关的url，When I try to open
浏览 76提问于2021-06-27得票数 0
我使用POSIX命名管道(fifos)从一个或多个线程发送记录，由另一个线程读取(只有一个线程进行读取)。然而，100项记录中的第83项记录被简单地删除了。客户端核心调用写，返回值被正确地报告为记录的长度(720字节)，因此客户端(编写者)核心确认记录被发送，但是切换到在gdb调试模式下的读取器核心，通过调度器锁定，我循环读取之前的几条记录，然后
浏览 4提问于2020-05-01得票数 1
回答已采纳
我有一个读线程和多个写线程，如下所示。state = lunch;//do something假设state是共享变量，读取线程在所有写线程之前进入等待状态假设这两个写线程同时尝试获取mutex，而write1获取mutex并发送cond。此时，write2和read线程都锁定在mutex上，据我所知，没有线程
浏览 3提问于2020-11-13得票数 2
回答已采纳
3回答
在通过管道定义时，我找到了以下语句:一个FIFO可以有多个读取器或多个写入器。来自每个写入器的字节以原子方式写入，最大大小为PIPE_BUF (在Linux上为4KB)。来自同时写入器的块可以交错。我不能理解“来自同时写入的数据块可以交错”。有人能解释一下吗？
浏览 0提问于2014-10-07得票数 3
1回答
我在两个不同的二进制文件中看到了不同的epoll和select行为，希望能得到一些调试帮助。在下文中，epoll_wait和select将互换使用。我有两个进程，一个写入器和一个读取器，它们通过fifo进行通信。读取器执行epoll_wait以获得写入通知。我还想知道写入器何时关闭先进先出，似乎epoll_wa
浏览 0提问于2012-10-26得票数 2
回答已采纳
5回答
java中的无限fifo
、、、
我正在寻找一种线程安全的无限阻塞fifo，它由固定的缓冲区支持，如数组。语义是多个读取器和写入器线程可以安全地访问它。如果缓冲区已满，写入器将阻塞并覆盖最旧的项。如果缓冲区为空，则读取器阻塞。当total and和total removed的计数器一次或多次绕过内部缓冲区大小时，必须保持Fifo排序。有趣的是，
浏览 0提问于2013-02-18得票数 0
回答已采纳
使用一个简单的父-子程序测试Linux epoll。当子代每秒钟写一个no时，父程序应该从管道中读取它，并且每秒钟写一个no到stdout。实际行为 int bSize=2;
char buf
浏览 0提问于2019-06-13得票数 1
1回答
例如，我创建了一个命名管道，如下所示：我从某个进程(例如，某个服务器)中读取。例如，我使用了尾：如果多个客户端进程将一些消息写入其中(例如，echo "msg" >> myPipe，是否有可能将消息交织在一起，如下所示：还是写到命名
浏览 0提问于2013-03-16得票数 38
回答已采纳
这是我的简单代码，它打开一个命名管道，向其中写入一个字符串，然后关闭该管道。管道是在另一个函数中创建的，如下所述。size_t written = write(jobq, ptr, size*nmemb);
// close fifoto report to other agents the
浏览 2提问于2014-06-08得票数 5
回答已采纳
1回答
我在read_fds中使用单个命名管道fd调用select。此命名管道没有写入器，只在非阻塞、只读模式下打开.我希望select返回标记为准备读取的命名管道fd，尝试从管道读取返回0：
#include <thread>{
//
浏览 4提问于2017-06-18得票数 4
回答已采纳
2回答
我想在两个JVM进程(不是同一个进程)之间创建一个读取/写入数据的管道。我在Unix中使用FIFO管道来共享数据。(); return res;和一个使用FileLock的作家： }
ret
浏览 3提问于2015-09-15得票数 1
回答已采纳
我很难使用命名管道(即用mkfifo创建)和文件描述符来重定向输出，并在ImageMagick (convert)中获取输入。)：
当一个FIFO被打开读取时，它会阻塞调用进程(通常)。当进程打开FIFO进行写入时，读取器就会被解除阻塞。当写入器关闭FIFO时，读取过程将获得EOF (0字节可读取)，除了关闭FIFO并重新打开之外，没有什么可以做的了。Open <
浏览 0提问于2016-04-23得票数 3
回答已采纳
1回答
我正在编写一个Linux fifo测试程序。int main(int argc, char *argv[]) if (argc > 1) int fd = open(".printf("Read %d bytes: %s\n", bytes, buf)
浏览 0提问于2018-06-06得票数 2
回答已采纳
1回答
这里是一个场景，我的父进程有一个范围(a，b)和一个数字N，我想计算(a，b)之间的所有素数。但处理部分由N个子进程完成。问题来了，如果只有一个子进程，我就可以遵循这个。如果多个进
浏览 4提问于2015-09-05得票数 2
我正在处理一个客户端服务器应用程序。下面是客户端的代码。 } printf("reader thread stop"); }
还有一个写入线程，它从服务器在事件更改上写入数据。("message written to pipe
浏览 3提问于2015-02-17得票数 0
回答已采纳
在我的应用程序中，我从我的socket.io侦听器(线程1)收到了一些点数
// socket.io background threa
浏览 0提问于2017-03-03得票数 1
我想知道Fober等人的论文中提出的先进先出队列是否是多消费者和生产者先进先出队列。如果不是，哪一个是记录最好的多消费者和生产者FIFO队列？
谢谢
浏览 0提问于2010-06-05得票数 3
回答已采纳
1回答
我有一个网络客户端库，它可以读/写一些网络套接字。
只有一个线程执行网络I/O并响应来自公开的客户端API的请求。这些客户端API请求将从FIFO队列中弹出。为了让线程处理请求，当我的主循环在epoll_wait上被阻塞时，我想我应该使用一个可以用epoll_ctl添加的eventfd。所以问题是，如果<em
浏览 2提问于2012-06-05得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
