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

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

#ifdef __cplusplus
#include "../src/PrecompiledHeaders.h"
#else
#import <Cocoa/Cocoa.h>
#endif

#define NUM_THREADS 8

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

@interface SubTask : NSObject {
@private
    NSString* ownerThreadName;
    NSNumber* taskNumber;
}
- (oneway void)setupServer;
- (oneway void)setupClient;
- (void)startThread:(NSArray*)data;
@end

@interface MainTask : NSObject {
@private
    NSConnection* connections[NUM_THREADS];
    SubTask* proxies[NUM_THREADS];
}
- (void)start;
- (void)setupServers;
- (void)setupClients;
- (void)addNewThread:(NSNumber*)taskNumber;
@end

@implementation MainTask
- (void)addNewThread:(NSNumber*)taskNumber {
        int task_num = [taskNumber intValue];
    NSLog(@"addNewThread %d", task_num);
        // [[[NSThread currentThread] threadDictionary] objectForKey:@"my_name"]
    NSLog(@"addNewThread [%s] %d", [[[[NSThread currentThread] threadDictionary] objectForKey:@"my_name"] UTF8String], task_num);
    proxies[task_num] = [(SubTask*)[[connections[task_num] rootProxy] retain] retain];
    NSLog(@"addNewThread [%s] %d rootProxy", [[[[NSThread currentThread] threadDictionary] objectForKey:@"my_name"] UTF8String], task_num);
    [self setupServers];
}

- (void)setupServers {
    int i = 0;
    for (i = 0; i < NUM_THREADS; i++) {
        if (proxies[i] == nil) {
            continue;
        }
        [proxies[i] setupServer];
    }
}

- (void)setupClients {
    int i = 0;
    for (i = 0; i < NUM_THREADS; i++) {
        if (proxies[i] == nil) {
            continue;
        }
        [proxies[i] setupClient];
    }
}

- (void)start {
    NSAutoreleasePool* pool = [[NSAutoreleasePool alloc] init];
    NSLog(@"start [%s]", [[[[NSThread currentThread] threadDictionary] objectForKey:@"my_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];
            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] threadDictionary] objectForKey:@"my_name"] UTF8String],
              [[localException name] UTF8String],
              [[localException reason] UTF8String]);
    }
    NS_ENDHANDLER

    [pool release];
}
@end

MainTask* mainTask = nil;

@implementation SubTask
- (oneway void)setupServer {
    NSLog(@"setupServer [%s] == [%s]", [[[[NSThread currentThread] threadDictionary] objectForKey:@"my_name"] UTF8String], [ownerThreadName UTF8String]);
}

- (oneway void)setupClient {
    NSLog(@"setupClient [%s] == [%s]", [[[[NSThread currentThread] threadDictionary] objectForKey:@"my_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];
        [[currentThread threadDictionary] setObject:ownerThreadName forKey:@"my_name"];
        //[currentThread setName:ownerThreadName];
        
        NSLog(@"ready [%s] %s", [[[[NSThread currentThread] threadDictionary] objectForKey:@"my_name"] UTF8String], [ownerThreadName UTF8String]);

        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] run];
    } 
    NS_HANDLER
    {
        NSLog(@"Objective-C exception [%s] name=[%s] reason=[%s]\n",
              [[[[NSThread currentThread] threadDictionary] objectForKey:@"my_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"];
        [[[NSThread currentThread] threadDictionary] setObject:@"main() thread" forKey:@"my_name"];

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

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

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