НОД и RunLoops

Question

В моем приложении я добавьте CFMachPortRef (через CFMachPortCreateRunLoopSource) до нитей CFRunLoop

Сейчас я задавал себе, это может быть сделано с помощью НОД? Скажем, вместо нерест моего NSThread и добавьте созданный CFRunLoopSourceRef его запуск цикла через CFRunLoopAddSource, добавьте порт события для runloop депеши в?

Я думаю, что это скорее всего не сработает из-за внутренней работы GCD, но я действительно не знаю.

Update

---

Я получил это до сих пор, однако ни функцию обратного вызова для крана событий, ни блок dispatch_source_event_handler называется. Есть идеи?

CFMachPortRef port = CGEventTapCreate(kCGSessionEventTap, 
             kCGHeadInsertEventTap, 
             opts, 
             desc_.eventMask, 
             _CGEventCallback, 
             self); 

// create dispatch source 
dispatch_source_t source = dispatch_source_create(DISPATCH_SOURCE_TYPE_MACH_RECV, 
                CFMachPortGetPort(port), 
                0, 
                dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)); 

// set event handler 
dispatch_source_set_event_handler(source, ^{ 
    printf("handle me!\n"); 
}); 

dispatch_resume(source); 

Answer 1

Фактически вы можете использовать GCD для контроля порта Mach, используя функцию dispatch_source_create(). Код будет выглядеть примерно так:

mach_port_t myPort; //assume you have this already 
dispatch_source_t portSource; 

portSource = dispatch_source_create(DISPATCH_SOURCE_TYPE_MACH_RECV, myPort, 0, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT)); 
dispatch_source_set_event_handler(portSource, ^(void) { //code for handling incoming message here }); 

dispatch_resume(portSource); 

Всякий раз, когда сообщение приходит в порт, блок вы передаете в качестве обработчика событий должен вызываться, и вы можете обработать сообщение там. Этот пример просто использует глобальную очередь, предоставленную GCD для обработки сообщения, но вы можете создать собственную очередь, если хотите.

Answer 2

Чтобы запланировать обратные вызовы из порта уведомлений в очереди GCD, вы можете использовать IONotificationPortSetDispatchQueue вместо CFRunLoopAddSource с Runloop.

Пример:

IOServiceOpen(driver, mach_task_self(), 0, &connection); 

notifyPort = IONotificationPortCreate(kIOMasterPortDefault); 

IOServiceAddInterestNotification(
    notifyPort, 
    driver, 
    kIOGeneralInterest, 
    myCallback, 
    NULL, //refcon 
    &notificationObject 
); 

// Instead of this: 
// CFRunLoopAddSource(CFRunLoopGetCurrent(), 
//     IONotificationPortGetRunLoopSource(notifyPort), 
//     kCFRunLoopDefaultMode); 
// do this: 
IONotificationPortSetDispatchQueue(notifyPort, myQueue); 

Это заставит myCallback() обработчик называться по очереди GCD myQueue.