Вдохновленный документацией Apple , я экспериментирую с использованием источника диспетчеризации GCD для асинхронного чтения из файла вместо традиционного NSInputStream
и подхода на основе цикла выполнения.
Однако я не уверен, как определить, когда я закончу читать файл. При NSInputStream
ваш делегат получает событие NSStreamEventEndEncountered
. Для источников рассылки я предположил, что обработчик событий будет вызываться в конце файла, но, похоже, это не так. Чего мне не хватает?
Вот мой код:
const char* fileName = "/Users/Nick/Music/iTunes/iTunes Music Library.xml";
int fd = open(fileName, O_NONBLOCK|O_RDONLY);
assert(fd>0);
dispatch_source_t readerSource = dispatch_source_create(DISPATCH_SOURCE_TYPE_READ, fd, 0, dispatch_get_main_queue());
dispatch_source_set_event_handler(readerSource, ^{
char buffer[1024];
size_t estimatedLength = dispatch_source_get_data(readerSource);
ssize_t bytesRead = read(fd, buffer, MIN(1024, estimatedLength));
if (bytesRead < 0) {
if (errno != EAGAIN) {
printf("Unexpected error!");
abort();
}
} else if (bytesRead > 0) {
printf("Got %ld bytes of data.\n", bytesRead);
} else {
// bytesRead == 0
printf("EOF encountered!\n");
dispatch_source_cancel(readerSource);
}
});
dispatch_source_set_cancel_handler(readerSource, ^{
printf("Cancel handler was called.\n");
close(fd);
dispatch_release(readerSource);
});
dispatch_resume(readerSource);