c-使用CreateEvent和WaitForMultipleObjects的端口程序到Linux

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c-使用CreateEvent和WaitForMultipleObjects的端口程序到Linux，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2438字，纯文字阅读大概需要4分钟。

内容图文

我需要将使用Windows API函数SetEvent,CreateEvent和WaitForMultipleObjects的多进程应用程序移植到Linux.我发现了许多与此问题有关的线程,但是没有一个线程为我的问题提供了合理的解决方案.

我有一个应用程序,它可以分为三个进程,并通过这些事件管理一个进程的线程工作池.

我对此问题有多种解决方案.一种是在Linux上使用mkfifo在FIFO上创建FIFO特殊文件,然后使用select语句唤醒线程.问题在于该解决方案的运行方式与WaitForMultipleObjects不同.例如,如果工作池中有10个线程将等待事件,而我调用SetEvent五次,则恰好五个工作线程将被唤醒并完成工作,在Linux中使用FIFO变体时,它将唤醒每个线程,即我在选择中语句并等待将数据放入fifo.描述此问题的最佳方法是Windows API的工作方式类似于一个计数为1的全局信号量.

我还考虑过使用pthreads和条件变量来重新创建它并通过共享内存(shm_open和mmap)共享变量,但是我在这里遇到了同样的问题！

在Linux上重新创建此行为的合理方法是什么？我发现有一些解决方案可以在单个流程中执行此操作,但是在多个流程之间执行此操作又如何呢？

任何想法都会受到赞赏(注意：我不希望有完整的实现,我只需要更多想法就可以开始解决此问题).

解决方法:

您可以使用信号量(sem_init),它们在共享内存上工作.如果您要从不同的进程初始化信号量,则也将其命名为(sem_open).如果您需要与员工交流信息,例如将实际任务传递给他们,那么解决此问题的一种方法是使用POSIX message queues.它们被命名并在进程间工作.这是一个简短的例子.请注意,只有第一个工作线程实际上会初始化消息队列,其他工作线程使用现有线程的属性.而且,它可能会保持持久,直到使用mq_unlink明确将其删除为止,为简单起见,在此将其跳过.

具有工作线程的接收器：

// Link with -lrt -pthread

#include <fcntl.h>
#include <mqueue.h>
#include <pthread.h>
#include <stdio.h>
#include <unistd.h>

void *receiver_thread(void *param) {
    struct mq_attr mq_attrs = { 0, 10, 254, 0 };

    mqd_t mq = mq_open("/myqueue", O_RDONLY | O_CREAT, 00644, &mq_attrs);
    if(mq < 0) {
        perror("mq_open");
        return NULL;
    }
    char msg_buf[255];
    unsigned prio;

    while(1) {
        ssize_t msg_len = mq_receive(mq, msg_buf, sizeof(msg_buf), &prio);
        if(msg_len < 0) {
            perror("mq_receive");
            break;
        }
        msg_buf[msg_len] = 0;
        printf("[%lu] Received: %s\n", pthread_self(), msg_buf);
        sleep(2);
    }
}

int main() {
    pthread_t workers[5];
    for(int i=0; i<5; i++) {
        pthread_create(&workers[i], NULL, &receiver_thread, NULL);
    }
    getchar();
}

发件人：

#include <fcntl.h>
#include <stdio.h>
#include <mqueue.h>
#include <unistd.h>

int main() {
    mqd_t mq = mq_open("/myqueue", O_WRONLY);
    if(mq < 0) {
        perror("mq_open");
    }
    char msg_buf[255];
    unsigned prio;

    for(int i=0; i<255; i++) {
        int msg_len = sprintf(msg_buf, "Message #%d", i);
        mq_send(mq, msg_buf, msg_len, 0);
        sleep(1);
    }
}

内容总结

以上是互联网集市为您收集整理的c-使用CreateEvent和WaitForMultipleObjects的端口程序到Linux全部内容，希望文章能够帮你解决c-使用CreateEvent和WaitForMultipleObjects的端口程序到Linux所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

---