Передача данных между потоками eventfd

Question

I wann переносит данные между потоками eventfd. Поэтому я пишу следующие коды для удовлетворения моих потребностей. Моя операционная система - openSUSE v12.3 64bit.

#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 между потоками. Мне тоже не нравится труба. Как я могу передавать данные один за другим правильно между потоками?

Answer 1

eventfd использует счетчик, поддерживаемый ядром, начиная со значения, предоставленного eventfd(). этот счетчик увеличивается на значение «отправлено» через write(), поэтому, если вы создаете eventfd с начальным значением 1, а затем write() 2, значение, которое вы читаете, будет равно 3. если вы затем напишите() 5 , значение read() будет равно 8 и так далее.

eventfd обычно используется потоками в шаблонах, управляемых событиями, но вам нужно использовать очередь или другой контейнер для передачи фактического значения или проверить signalfd(), который может использоваться для получения данных, присоединенных к сигналам, посредством sigqueue().