macos - dispatch_write()和dispatch_read()的用法

我只是在玩一些GCD函数，用于将数据写入和读取文件。其中的两个功能是dispatch_write()和dispatch_read()，它们允许一个人将数据写入文件描述符并读取文件描述符，而无需设置新的dispatch_io_t channel 。

因此，我有以下代码:

#import <dispatch/dispatch.h>
#import <stdio.h>
#import <unistd.h>

int main() {
    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

    int intbuffer[] = { 1, 2, 3, 4 };
    dispatch_data_t data = dispatch_data_create(intbuffer, 4 * sizeof(int), queue, NULL);

    // Write
    dispatch_fd_t fd = open("data.dat", O_RDWR);
    printf("FD: %d\n", fd);

    dispatch_write(fd, data, queue,^(dispatch_data_t d, int e) {
        printf("Written %zu bytes!\n", dispatch_data_get_size(d));
        printf("\tError: %d\n", e);
    });

    close(fd);

    // Read
    fd = open("data.dat", O_RDWR);

    dispatch_read(fd, 4 * sizeof(int), queue, ^(dispatch_data_t d, int e) {
        printf("Read %zu bytes!\n", dispatch_data_get_size(d));
        printf("\tError: %d\n", e);
    });

    close(fd);

    // Exit confirmation
    getchar();

    return 0;
}

我试图用它向文件中写入一个4整数数组，然后再将其读回。我以前使用data.dat命令创建了touch，任何人都可以完全访问它(sudo chmod 777 data.dat)。

当我执行此代码时，似乎data.dat成功打开，因为该程序会打印出FD: 3，这是一个有效的文件描述符，但是dispatch_write并未向其中写入任何内容，因为我得到了:

Written 0 bytes!
    Error: 9
Read 0 bytes!
    Error: 9

错误9是EBADF错误的代码，但同样，3是有效的文件描述符。

那么，我在做什么错呢？

最佳答案

dispatch_read和dispatch_write不是同步调用-这就是它们的重点。换句话说，在这里设置的方式是，在调用close之后立即对文件描述符dispatch_write。到GCD在后台线程上执行写操作时，文件描述符已经关闭。读取操作相同。您必须等到写入操作完成后才能关闭文件。

我对您的代码做了一些修改，以使用dispatch_semaphore等待读写操作完成后再关闭文件:

int main() {
    dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

    int intbuffer[] = { 1, 2, 3, 4 };
    dispatch_data_t data = dispatch_data_create(intbuffer, 4 * sizeof(int), queue, NULL);

    dispatch_semaphore_t sem = dispatch_semaphore_create(0);
    // Write
    dispatch_fd_t fd = open("/tmp/data.dat", O_RDWR | O_CREAT | O_TRUNC, S_IRWXU | S_IRWXG | S_IRWXO);

    printf("FD: %d\n", fd);

    dispatch_write(fd, data, queue,^(dispatch_data_t d, int e) {
        printf("Written %zu bytes!\n", dispatch_data_get_size(data) - (d ? dispatch_data_get_size(d) : 0));
        printf("\tError: %d\n", e);
        dispatch_semaphore_signal(sem);
    });

    dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER);

    close(fd);

    // Read
    fd = open("/tmp/data.dat", O_RDWR);

    dispatch_read(fd, 4 * sizeof(int), queue, ^(dispatch_data_t d, int e) {
        printf("Read %zu bytes!\n", dispatch_data_get_size(d));
        printf("\tError: %d\n", e);
        dispatch_semaphore_signal(sem);
    });

    dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER);
    close(fd);

    // Exit confirmation
    getchar();

    return 0;
}