dispatch_write()和dispatch_read()用法
我只是在玩一些GCD函数，用于将数据写入文件和读取数据。其中两个函数是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: 3，这是一个有效的文件描述符，但是dispatch_write没有向它写任何东西，因为我得到：
Written 0 bytes!
Error: 9
Read 0 bytes!
Error: 9错误9是EBADF错误的代码，但同样，3是一个有效的文件描述符。
那我做错什么了？
回答 1
Stack Overflow用户
发布于 2013-07-31 12:50:27
dispatch_read和dispatch_write不是同步调用--这就是它们的全部要点。换句话说，在这里设置它的方式是，在调用close之后立即使用文件描述符。当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;
}https://stackoverflow.com/questions/17948903
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号