5

ファイルへのデータの書き込みと読み取りのためのいくつかの GCD 関数で遊んでいます。これらの関数のうちの 2 つはdispatch_write()とで、新しいチャネルdispatch_read()を設定することなくファイル記述子にデータを読み書きできるようにします。dispatch_io_t

だから、私は次のコードを持っています：

#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: 3dispatch_write

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

エラー 9 はエラーのコードですEBADFが、3 は有効なファイル記述子です。

それで、私は何を間違っていますか？

4

1 に答える 1

7

dispatch_read同期呼び出しではありdispatch_writeません-それが彼らの要点です。つまり、ここで設定した方法では、 をclose呼び出した直後にファイル記述子が作成されますdispatch_write。GCD がバックグラウンド スレッドで書き込みを実行するまでに、ファイル記述子は既に閉じられています。読み取り操作も同様です。ファイルを閉じる前に、書き込み操作が完了するまで待つ必要があります。

dispatch_semaphoreファイルを閉じる前に書き込みと読み取りが完了するのを待つためにa を使用するように、コードを少し作り直しました。

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;
}
于 2013-07-31T12:50:27.770 に答える