3

eventfd でスレッド間でデータを転送したい。そのため、必要に応じて次のコードを記述します。私のホスト OS は openSUSE v12.3 64 ビットです。

 #include "stdio.h"
 #include "unistd.h"
 #include "pthread.h"
 #include "sys/eventfd.h"
 #include "sys/epoll.h"
 #define nil NULL

 int efd = -1;

 void* read_thread(void* arg)   {

        int ret = 0;
    uint64_t count = 0;
    int ep_fd = -1;
    struct epoll_event events[10];

    (void)(arg);
    if (efd < 0) {
        printf("efd not inited.\n");
        return nil;
    }

    ep_fd = epoll_create(1024);
    if (ep_fd < 0) {
        perror("epoll_create fail: ");
        return nil;
    }

    {
        struct epoll_event read_event;

        read_event.events = EPOLLIN;
        read_event.data.fd = efd;

        ret = epoll_ctl(ep_fd, EPOLL_CTL_ADD, efd, &read_event);
        if (ret < 0) {
            perror("epoll ctl failed:");
            return nil;
        }
    }

    while (1) {
        ret = epoll_wait(ep_fd, events, 10, 5000);
        if (ret > 0) {
            int i = 0;
            for (i = 0; i < ret; i++) {
                if (events[i].events & (EPOLLHUP | EPOLLERR)) {
                    printf("epoll eventfd has epoll hup.\n");
                    break;
                } else if (events[i].events & EPOLLIN) {
                    int event_fd = events[i].data.fd;
                    ret = eventfd_read(event_fd, &count);
                    if (ret < 0) {
                        perror("read fail:");
                        break;
                    } else {
                        printf("read %llu\n", count);
                    }
                }
            }
        } else if (ret == 0) {
            break;
        } else {
            perror("epoll wait error:");
            break;
        }
    }

    close(ep_fd);
    return nil;
}

int main(int argc, char *argv[]) {

    pthread_t pid = 0;
    uint64_t count = 0;
    int ret = 0;
    int i = 0;

    efd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC);
    if (efd < 0) {
        perror("eventfd failed.");
        return -1;
    }

    ret = pthread_create(&pid, NULL, read_thread, NULL);
    if (ret < 0) {
        perror("pthread create:");
        close(efd);
        return -2;
    }

    for (i = 0; i < 5; i++) {
        count = i + 1;
        ret = eventfd_write(efd, count);
        if (ret < 0) {
            perror("write event fd fail:");
            break;
        } else {
            printf("write %llu\n", count);
        }
    }

    sleep(3);

    pthread_join(pid, NULL);
    close(efd);
    efd = -1;

    return 0;
}

eventfd の振る舞いはパイプのようなものであるべきだと思います。したがって、プログラムの出力結果は次のようになります。

書き込み 1 読み取り 1 書き込み 2 読み取り 2 書き込み 3 読み取り 3 書き込み 4 読み取り 4 書き込み 5 読み取り 5

ただし、実際の結果は次のとおりです。

書き込み 1 書き込み 2 書き込み 3 書き込み 4 書き込み 5 読み取り 15

また

書き込み 1 書き込み 2 書き込み 3 書き込み 4 書き込み 5 読み取り 1 読み取り 14

出力結果が入力結果の合計である理由を教えてください。

スレッド間のeventfdでデータを正しく転送できません。私もパイプは苦手です。スレッド間でデータを 1 つずつ正しく転送するにはどうすればよいですか?

4

1 に答える 1

6

eventfd は、eventfd() に提供された値から始まる、カーネルによって維持されるカウンターを使用します。このカウンタは、write() 経由で「送信された」値によってインクリメントされるため、初期値 1 で eventfd を作成してから write() 2 を実行すると、読み取られる値は 3 になります。 、read() 値は 8 などになります。

eventfd はイベント駆動型パターン内のスレッドで一般的に使用されますが、実際の値を渡すにはキューまたは他のコンテナーを使用するか、sigqueue() によってシグナルに添付されたデータを受信するために使用できる signalfd() を確認する必要があります。

于 2013-11-25T22:35:33.417 に答える