root/lang/objective-cplusplus/i3/trunk/tmp/onmainthread.cpp @ 36471

// -*- coding: utf-8-dos -*-

#import <Cocoa/Cocoa.h>

#define NUM_THREADS 20

// [NSThread sleepUntilDate:[[NSDate date] addTimeInterval:0.5]];
// [[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:10]];

@interface MainTask : NSObject {
@public
    NSConnection* connections[NUM_THREADS];
}
- (void)start;
- (void)say:(NSString*)message;
- (void)addNewThread:(NSNumber*)taskNumber;
@end

@interface SubTask : NSObject {
@public
    NSString* ownerThreadName;
    NSNumber* taskNumber;
}
- (oneway void)handleProxy;
- (oneway void)handleProxy2:(int)sender;
- (void)startThread:(NSArray*)data;
@end

SubTask* proxies[NUM_THREADS];

@implementation MainTask
- (void)say:(NSString*)message {    
    NSLog(@"say [%s] %s", [[[NSThread currentThread] name] UTF8String], [message UTF8String]);
}
- (void)addNewThread:(NSNumber*)taskNumber {
    int task_num = [taskNumber intValue];
    NSLog(@"addNewThread [%s] %d", [[[NSThread currentThread] name] UTF8String], task_num);
    proxies[task_num] = (SubTask*)[connections[task_num] rootProxy];
    NSLog(@"addNewThread [%s] %d rootProxy", [[[NSThread currentThread] name] UTF8String], task_num);
    [proxies[task_num] handleProxy];    
}

- (void)start {
    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];
    NSLog(@"start [%s]", [[[NSThread currentThread] name] UTF8String]);

    NS_DURING
    {
        int task_num = 0;
        for (task_num = 0; task_num < NUM_THREADS; task_num++) {
            NSNumber* taskNumber = [[NSNumber numberWithInt:task_num] retain];
            proxies[task_num] = nil;
            NSPort* port1 = [[NSPort port] retain];
            NSPort* port2 = [[NSPort port] retain];
            if (port1 == nil) {
                NSLog(@"port1 == nil");
                return;
            }
            if (port2 == nil) {
                NSLog(@"port2 == nil");
                return;
            }
            connections[task_num] =
                [[NSConnection alloc] initWithReceivePort:port1
                                      sendPort:port2];
            [connections[task_num] retain];
            NSArray* data = [[NSArray arrayWithObjects:taskNumber, port1, port2, nil] retain];
            SubTask* task = [[[SubTask alloc] init] retain];
            [NSThread detachNewThreadSelector:@selector(startThread:)
                      toTarget:task
                      withObject:data];
        }
    }
    NS_HANDLER
    {
        NSLog(@"Objective-C exception [%s] name=[%s] reason=[%s]\n",
              [[[NSThread currentThread] name] UTF8String],
              [[localException name] UTF8String],
              [[localException reason] UTF8String]);
    }
    NS_ENDHANDLER

    [pool release];
}
@end

MainTask* mainTask = nil;

@implementation SubTask
- (oneway void)handleProxy2:(int)sender {
    NSLog(@"handleProxy2 [%s] sender=%d", [[[NSThread currentThread] name] UTF8String], sender);
}

- (oneway void)handleProxy {
    NSLog(@"handleProxy [%s] %s", [[[NSThread currentThread] name] UTF8String], [ownerThreadName UTF8String]);
}

- (void)startThread:(NSArray*)data {
    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];

    NS_DURING
    {
        taskNumber = [data objectAtIndex:0];
        NSPort* port1 = [data objectAtIndex:1];
        NSPort* port2 = [data objectAtIndex:2];

        ownerThreadName = [@"SubTask" stringByAppendingString:[taskNumber description]];
        [ownerThreadName retain];

        NSThread* currentThread = [NSThread currentThread];
        NSString* name = [currentThread name];
        if (name != nil) {
            NSLog(@"warning [[NSThread currentThread] name] is already set \"%s\"", name);
        }
        [currentThread setName:ownerThreadName];
        
        NSLog(@"ready [%s] %s", [[[NSThread currentThread] name] UTF8String], [ownerThreadName UTF8String]);

        //@synchronized (mainTask) {
        //    [mainTask performSelectorOnMainThread:@selector(say:) withObject:ownerThreadName waitUntilDone:NO];
        //}

        NSConnection *serverConnection =
            [NSConnection connectionWithReceivePort:port2
                          sendPort:port1];
        [serverConnection retain];
        [serverConnection setRootObject:self];
        
        [[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:1]];

        @synchronized (mainTask) {
            [mainTask performSelectorOnMainThread:@selector(addNewThread:) withObject:taskNumber waitUntilDone:NO];
        }

        [[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:3]];

        // invoke proxy
        NSLog(@"execute handleProxy2 [%s]", [[[NSThread currentThread] name] UTF8String]);
        int n = [taskNumber intValue];
        SubTask* p = proxies[(n + 1) % NUM_THREADS];
        @synchronized (p) {
            if (p == nil) {
                NSLog(@"p == nil");
                return;
            }
            [p handleProxy2:n];
        }

        [[NSRunLoop currentRunLoop] run];
    } 
    NS_HANDLER
    {
        NSLog(@"Objective-C exception [%s] name=[%s] reason=[%s]\n",
              [[[NSThread currentThread] name] UTF8String],
              [[localException name] UTF8String],
              [[localException reason] UTF8String]);
    }
    NS_ENDHANDLER

    [pool release];
}
@end

int main() {
    fputs("main()\n", stderr);
    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];

    NS_DURING
    {
        [NSApplication sharedApplication];

        [[NSThread currentThread] setName:@"main() thread"];

        mainTask = [[MainTask alloc] init];
        [mainTask performSelectorOnMainThread:@selector(start) withObject:nil waitUntilDone:NO];

        [[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:10]];
    }
    NS_HANDLER
    {
        NSLog(@"Objective-C exception [%s] name=[%s] reason=[%s]\n",
              [[[NSThread currentThread] name] UTF8String],
              [[localException name] UTF8String],
              [[localException reason] UTF8String]);
    }
    NS_ENDHANDLER

    [pool release];
    fputs("main() return\n", stderr);
    return 0;
}