1 - (void)threadMain
 2 {
 3     // The application uses garbage collection, so no autorelease pool is needed.
 4     NSRunLoop* myRunLoop = [NSRunLoop currentRunLoop];
 5  
 6     // Create a run loop observer and attach it to the run loop.
 7     CFRunLoopObserverContext  context = {0, self, NULL, NULL, NULL};
 8     CFRunLoopObserverRef    observer = CFRunLoopObserverCreate(kCFAllocatorDefault,
 9             kCFRunLoopAllActivities, YES, 0, &myRunLoopObserver, &context);
10  
11     if (observer)
12     {
13         CFRunLoopRef    cfLoop = [myRunLoop getCFRunLoop];
14         CFRunLoopAddObserver(cfLoop, observer, kCFRunLoopDefaultMode);
15     }
16  
17     // Create and schedule the timer.
18     [NSTimer scheduledTimerWithTimeInterval:0.1 target:self
19                 selector:@selector(doFireTimer:) userInfo:nil repeats:YES];
20  
21     NSInteger    loopCount = 10;
22     do
23     {
24         // Run the run loop 10 times to let the timer fire.
25         [myRunLoop runUntilDate:[NSDate dateWithTimeIntervalSinceNow:1]];
26         loopCount--;
27     }
28     while (loopCount);
29 }

 1 - (void)skeletonThreadMain
 2 {
 3     // Set up an autorelease pool here if not using garbage collection.
 4     BOOL done = NO;
 5  
 6     // Add your sources or timers to the run loop and do any other setup.
 7  
 8     do
 9     {
10         // Start the run loop but return after each source is handled.
11         SInt32    result = CFRunLoopRunInMode(kCFRunLoopDefaultMode, 10, YES);
12  
13         // If a source explicitly stopped the run loop, or if there are no
14         // sources or timers, go ahead and exit.
15         if ((result == kCFRunLoopRunStopped) || (result == kCFRunLoopRunFinished))
16             done = YES;
17  
18         // Check for any other exit conditions here and set the
19         // done variable as needed.
20     }
21     while (!done);
22  
23     // Clean up code here. Be sure to release any allocated autorelease pools.
24 }

 1 @interface RunLoopSource : NSObject
 2 {
 3     CFRunLoopSourceRef runLoopSource;
 4     NSMutableArray* commands;
 5 }
 6  
 7 - (id)init;
 8 - (void)addToCurrentRunLoop;
 9 - (void)invalidate;
10  
11 // Handler method
12 - (void)sourceFired;
13  
14 // Client interface for registering commands to process
15 - (void)addCommand:(NSInteger)command withData:(id)data;
16 - (void)fireAllCommandsOnRunLoop:(CFRunLoopRef)runloop;
17  
18 @end
19  
20 // These are the CFRunLoopSourceRef callback functions.
21 void RunLoopSourceScheduleRoutine (void *info, CFRunLoopRef rl, CFStringRef mode);
22 void RunLoopSourcePerformRoutine (void *info);
23 void RunLoopSourceCancelRoutine (void *info, CFRunLoopRef rl, CFStringRef mode);
24  
25 // RunLoopContext is a container object used during registration of the input source.
26 @interface RunLoopContext : NSObject
27 {
28     CFRunLoopRef        runLoop;
29     RunLoopSource*        source;
30 }
31 @property (readonly) CFRunLoopRef runLoop;
32 @property (readonly) RunLoopSource* source;
33  
34 - (id)initWithSource:(RunLoopSource*)src andLoop:(CFRunLoopRef)loop;
35 @end

1 void RunLoopSourceScheduleRoutine (void *info, CFRunLoopRef rl, CFStringRef mode)
2 {
3     RunLoopSource* obj = (RunLoopSource*)info;
4     AppDelegate*   del = [AppDelegate sharedAppDelegate];
5     RunLoopContext* theContext = [[RunLoopContext alloc] initWithSource:obj andLoop:rl];
6  
7     [del performSelectorOnMainThread:@selector(registerSource:)
8                                 withObject:theContext waitUntilDone:NO];
9 }

1 void RunLoopSourcePerformRoutine (void *info)
2 {
3     RunLoopSource*  obj = (RunLoopSource*)info;
4     [obj sourceFired];
5 }

 1 - (id)init
 2 {
 3     CFRunLoopSourceContext    context = {0, self, NULL, NULL, NULL, NULL, NULL,
 4                                         &RunLoopSourceScheduleRoutine,
 5                                         RunLoopSourceCancelRoutine,
 6                                         RunLoopSourcePerformRoutine};
 7  
 8     runLoopSource = CFRunLoopSourceCreate(NULL, 0, &context);
 9     commands = [[NSMutableArray alloc] init];
10  
11     return self;
12 }
13  
14 - (void)addToCurrentRunLoop
15 {
16     CFRunLoopRef runLoop = CFRunLoopGetCurrent();
17     CFRunLoopAddSource(runLoop, runLoopSource, kCFRunLoopDefaultMode);
18 }

 1 - (void)registerSource:(RunLoopContext*)sourceInfo;
 2 {
 3     [sourcesToPing addObject:sourceInfo];
 4 }
 5  
 6 - (void)removeSource:(RunLoopContext*)sourceInfo
 7 {
 8     id    objToRemove = nil;
 9  
10     for (RunLoopContext* context in sourcesToPing)
11     {
12         if ([context isEqual:sourceInfo])
13         {
14             objToRemove = context;
15             break;
16         }
17     }
18  
19     if (objToRemove)
20         [sourcesToPing removeObject:objToRemove];
21 }

1 - (void)fireCommandsOnRunLoop:(CFRunLoopRef)runloop
2 {
3     CFRunLoopSourceSignal(runLoopSource);
4     CFRunLoopWakeUp(runloop);
5 }

 1 NSRunLoop* myRunLoop = [NSRunLoop currentRunLoop];
 2  
 3 // Create and schedule the first timer.
 4 NSDate* futureDate = [NSDate dateWithTimeIntervalSinceNow:1.0];
 5 NSTimer* myTimer = [[NSTimer alloc] initWithFireDate:futureDate
 6                         interval:0.1
 7                         target:self
 8                         selector:@selector(myDoFireTimer1:)
 9                         userInfo:nil
10                         repeats:YES];
11 [myRunLoop addTimer:myTimer forMode:NSDefaultRunLoopMode];
12  
13 // Create and schedule the second timer.
14 [NSTimer scheduledTimerWithTimeInterval:0.2
15                         target:self
16                         selector:@selector(myDoFireTimer2:)
17                         userInfo:nil
18                         repeats:YES];

1 CFRunLoopRef runLoop = CFRunLoopGetCurrent();
2 CFRunLoopTimerContext context = {0, NULL, NULL, NULL, NULL};
3 CFRunLoopTimerRef timer = CFRunLoopTimerCreate(kCFAllocatorDefault, 0.1, 0.3, 0, 0,
4                                         &myCFTimerCallback, &context);
5  
6 CFRunLoopAddTimer(runLoop, timer, kCFRunLoopCommonModes);

 1 - (void)launchThread
 2 {
 3     NSPort* myPort = [NSMachPort port];
 4     if (myPort)
 5     {
 6         // This class handles incoming port messages.
 7         [myPort setDelegate:self];
 8  
 9         // Install the port as an input source on the current run loop.
10         [[NSRunLoop currentRunLoop] addPort:myPort forMode:NSDefaultRunLoopMode];
11  
12         // Detach the thread. Let the worker release the port.
13         [NSThread detachNewThreadSelector:@selector(LaunchThreadWithPort:)
14                toTarget:[MyWorkerClass class] withObject:myPort];
15     }
16 }

 1 #define kCheckinMessage 100
 2  
 3 // Handle responses from the worker thread.
 4 - (void)handlePortMessage:(NSPortMessage *)portMessage
 5 {
 6     unsigned int message = [portMessage msgid];
 7     NSPort* distantPort = nil;
 8  
 9     if (message == kCheckinMessage)
10     {
11         // Get the worker thread’s communications port.
12         distantPort = [portMessage sendPort];
13  
14         // Retain and save the worker port for later use.
15         [self storeDistantPort:distantPort];
16     }
17     else
18     {
19         // Handle other messages.
20     }
21 }

 1 +(void)LaunchThreadWithPort:(id)inData
 2 {
 3     NSAutoreleasePool*  pool = [[NSAutoreleasePool alloc] init];
 4  
 5     // Set up the connection between this thread and the main thread.
 6     NSPort* distantPort = (NSPort*)inData;
 7  
 8     MyWorkerClass*  workerObj = [[self alloc] init];
 9     [workerObj sendCheckinMessage:distantPort];
10     [distantPort release];
11  
12     // Let the run loop process things.
13     do
14     {
15         [[NSRunLoop currentRunLoop] runMode:NSDefaultRunLoopMode
16                             beforeDate:[NSDate distantFuture]];
17     }
18     while (![workerObj shouldExit]);
19  
20     [workerObj release];
21     [pool release];
22 }

 1 // Worker thread check-in method
 2 - (void)sendCheckinMessage:(NSPort*)outPort
 3 {
 4     // Retain and save the remote port for future use.
 5     [self setRemotePort:outPort];
 6  
 7     // Create and configure the worker thread port.
 8     NSPort* myPort = [NSMachPort port];
 9     [myPort setDelegate:self];
10     [[NSRunLoop currentRunLoop] addPort:myPort forMode:NSDefaultRunLoopMode];
11  
12     // Create the check-in message.
13     NSPortMessage* messageObj = [[NSPortMessage alloc] initWithSendPort:outPort
14                                          receivePort:myPort components:nil];
15  
16     if (messageObj)
17     {
18         // Finish configuring the message and send it immediately.
19         [messageObj setMsgid:kCheckinMessage];
20         [messageObj sendBeforeDate:[NSDate date]];
21     }
22 }

 1 NSPort* localPort = [[[NSMessagePort alloc] init] retain];
 2  
 3 // Configure the object and add it to the current run loop.
 4 [localPort setDelegate:self];
 5 [[NSRunLoop currentRunLoop] addPort:localPort forMode:NSDefaultRunLoopMode];
 6  
 7 // Register the port using a specific name. The name must be unique.
 8 NSString* localPortName = [NSString stringWithFormat:@"MyPortName"];
 9 [[NSMessagePortNameServer sharedInstance] registerPort:localPort
10                      name:localPortName];

 1 #define kThreadStackSize        (8 *4096)
 2  
 3 OSStatus MySpawnThread()
 4 {
 5     // Create a local port for receiving responses.
 6     CFStringRef myPortName;
 7     CFMessagePortRef myPort;
 8     CFRunLoopSourceRef rlSource;
 9     CFMessagePortContext context = {0, NULL, NULL, NULL, NULL};
10     Boolean shouldFreeInfo;
11  
12     // Create a string with the port name.
13     myPortName = CFStringCreateWithFormat(NULL, NULL, CFSTR("com.myapp.MainThread"));
14  
15     // Create the port.
16     myPort = CFMessagePortCreateLocal(NULL,
17                 myPortName,
18                 &MainThreadResponseHandler,
19                 &context,
20                 &shouldFreeInfo);
21  
22     if (myPort != NULL)
23     {
24         // The port was successfully created.
25         // Now create a run loop source for it.
26         rlSource = CFMessagePortCreateRunLoopSource(NULL, myPort, 0);
27  
28         if (rlSource)
29         {
30             // Add the source to the current run loop.
31             CFRunLoopAddSource(CFRunLoopGetCurrent(), rlSource, kCFRunLoopDefaultMode);
32  
33             // Once installed, these can be freed.
34             CFRelease(myPort);
35             CFRelease(rlSource);
36         }
37     }
38  
39     // Create the thread and continue processing.
40     MPTaskID        taskID;
41     return(MPCreateTask(&ServerThreadEntryPoint,
42                     (void*)myPortName,
43                     kThreadStackSize,
44                     NULL,
45                     NULL,
46                     NULL,
47                     0,
48                     &taskID));
49 }

 1 #define kCheckinMessage 100
 2  
 3 // Main thread port message handler
 4 CFDataRef MainThreadResponseHandler(CFMessagePortRef local,
 5                     SInt32 msgid,
 6                     CFDataRef data,
 7                     void* info)
 8 {
 9     if (msgid == kCheckinMessage)
10     {
11         CFMessagePortRef messagePort;
12         CFStringRef threadPortName;
13         CFIndex bufferLength = CFDataGetLength(data);
14         UInt8* buffer = CFAllocatorAllocate(NULL, bufferLength, 0);
15  
16         CFDataGetBytes(data, CFRangeMake(0, bufferLength), buffer);
17         threadPortName = CFStringCreateWithBytes (NULL, buffer, bufferLength, kCFStringEncodingASCII, FALSE);
18  
19         // You must obtain a remote message port by name.
20         messagePort = CFMessagePortCreateRemote(NULL, (CFStringRef)threadPortName);
21  
22         if (messagePort)
23         {
24             // Retain and save the thread’s comm port for future reference.
25             AddPortToListOfActiveThreads(messagePort);
26  
27             // Since the port is retained by the previous function, release
28             // it here.
29             CFRelease(messagePort);
30         }
31  
32         // Clean up.
33         CFRelease(threadPortName);
34         CFAllocatorDeallocate(NULL, buffer);
35     }
36     else
37     {
38         // Process other messages.
39     }
40  
41     return NULL;
42 }

 1 OSStatus ServerThreadEntryPoint(void* param)
 2 {
 3     // Create the remote port to the main thread.
 4     CFMessagePortRef mainThreadPort;
 5     CFStringRef portName = (CFStringRef)param;
 6  
 7     mainThreadPort = CFMessagePortCreateRemote(NULL, portName);
 8  
 9     // Free the string that was passed in param.
10     CFRelease(portName);
11  
12     // Create a port for the worker thread.
13     CFStringRef myPortName = CFStringCreateWithFormat(NULL, NULL, CFSTR("com.MyApp.Thread-%d"), MPCurrentTaskID());
14  
15     // Store the port in this thread’s context info for later reference.
16     CFMessagePortContext context = {0, mainThreadPort, NULL, NULL, NULL};
17     Boolean shouldFreeInfo;
18     Boolean shouldAbort = TRUE;
19  
20     CFMessagePortRef myPort = CFMessagePortCreateLocal(NULL,
21                 myPortName,
22                 &ProcessClientRequest,
23                 &context,
24                 &shouldFreeInfo);
25  
26     if (shouldFreeInfo)
27     {
28         // Couldn‘t create a local port, so kill the thread.
29         MPExit(0);
30     }
31  
32     CFRunLoopSourceRef rlSource = CFMessagePortCreateRunLoopSource(NULL, myPort, 0);
33     if (!rlSource)
34     {
35         // Couldn‘t create a local port, so kill the thread.
36         MPExit(0);
37     }
38  
39     // Add the source to the current run loop.
40     CFRunLoopAddSource(CFRunLoopGetCurrent(), rlSource, kCFRunLoopDefaultMode);
41  
42     // Once installed, these can be freed.
43     CFRelease(myPort);
44     CFRelease(rlSource);
45  
46     // Package up the port name and send the check-in message.
47     CFDataRef returnData =http://www.mamicode.com/ nil;
48     CFDataRef outData;
49     CFIndex stringLength = CFStringGetLength(myPortName);
50     UInt8* buffer = CFAllocatorAllocate(NULL, stringLength, 0);
51  
52     CFStringGetBytes(myPortName,
53                 CFRangeMake(0,stringLength),
54                 kCFStringEncodingASCII,
55                 0,
56                 FALSE,
57                 buffer,
58                 stringLength,
59                 NULL);
60  
61     outData =http://www.mamicode.com/ CFDataCreate(NULL, buffer, stringLength);
62  
63     CFMessagePortSendRequest(mainThreadPort, kCheckinMessage, outData, 0.1, 0.0, NULL, NULL);
64  
65     // Clean up thread data structures.
66     CFRelease(outData);
67     CFAllocatorDeallocate(NULL, buffer);
68  
69     // Enter the run loop.
70     CFRunLoopRun();
71 }