GCD와 RunLoops 내 응용 프로그램에서

Question

내가 추가 CFMachPortRef이가 GCD를 사용하여 수행 할 수 있습니다 내가 나 자신을 요구 한 스레드 CFRunLoop 이제

에 (CFMachPortCreateRunLoopSource를 통해)? 의 말을 대신 내 자신의 NSThread 산란과 파견의 runloop에 이벤트 포트를, CFRunLoopAddSource를 통해 자사의 실행 루프를 생성 CFRunLoopSourceRef을 추가하자?

나는 이것이 GCD의 내부 동작으로 인해 거의 작동하지 않을 것이라고 생각하지만 실제로는 모른다.

업데이트

---

I은 ​​이벤트 탭이 지금까지, 그러나 콜백 기능도있어 나 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를 사용하여 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 큐의 알림 포트에서 콜백을 예약하려면 Runloop에 CFRunLoopAddSource 대신 IONotificationPortSetDispatchQueue을 사용할 수 있습니다.

예 :

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); 

이는 GCD 큐 myQueue 호출 할 수있는 myCallback() 핸들러의 원인이됩니다.