root/lang/objective-cplusplus/i3/trunk/tmp/nc.cpp @ 36256

#include <mil/PrecompiledHeaders.h>
#include <mil/Synchronize.h>

const int NUM_THREADS = 3;
mil::Mutex mutex;
NSPort* ports1[NUM_THREADS][NUM_THREADS];
NSPort* ports2[NUM_THREADS][NUM_THREADS];

@interface WorkerObj : NSObject {
@public    
    int thread_id;
}
- (oneway void)someInt:(int)foo;
@end

@implementation WorkerObj
- (oneway void)someInt:(int)foo
{
    NSLog(@"someInt in thread %d, %d", [NSThread currentThread], foo);
}
- (void)handleNotification3:(NSNotification*)notification
{
    NSLog(@"notification3: %d", thread_id);

    synchronized (mutex) {
        for (int i = 0; i < NUM_THREADS; i++) {
            ports1[thread_id][i] = [NSPort port];
            ports2[thread_id][i] = [NSPort port];
        }
    }
}

- (void)handleNotification2:(NSNotification*)notification
{
    NSLog(@"notification2: %d", thread_id);

    for (int i = 0; i < NUM_THREADS; i++) {
        if (i == thread_id) {
            continue;
        }

        NSPort* port1 = nil;
        NSPort* port2 = nil;
        synchronized (mutex) {
            port1 = ports1[i][thread_id];
            port2 = ports2[i][thread_id];
        }

        if (port1 == nil || port2 == nil) {
            continue;
        }

        NSConnection *serverConnection =
            [NSConnection connectionWithReceivePort:port2 sendPort:port1];
        [serverConnection setRootObject:self];
    }

}

- (void)handleNotification1:(NSNotification*)notification
{
    NSLog(@"notification1: %d", thread_id);
    
    for (int i = 0; i < NUM_THREADS; i++) {
        if (i == thread_id) {
            continue;
        }

        NSPort* port1 = nil;
        NSPort* port2 = nil;
        synchronized (mutex) {
            port1 = ports1[thread_id][i];
            port2 = ports2[thread_id][i];
        }
            
        NSConnection *connection =
            [[NSConnection alloc] initWithReceivePort:port1 sendPort:port2];
            
        WorkerObj* mainThreadProxy = (WorkerObj*)[connection rootProxy];
        [mainThreadProxy someInt: 10 * thread_id];
    }

}
@end

void* thread_routine(void* foo) {
    int thread_id = (int)foo;
    sleep(1);
    
    NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];

    NSLog(@"thread %d", thread_id);

    WorkerObj* obj = [[WorkerObj alloc] init];
    obj->thread_id = thread_id;

    NSNotificationCenter* center = [NSNotificationCenter defaultCenter];
    [center addObserver:obj selector:@selector(handleNotification1:) name:@"TestNotification1" object:nil];
    [center addObserver:obj selector:@selector(handleNotification2:) name:@"TestNotification2" object:nil];
    [center addObserver:obj selector:@selector(handleNotification3:) name:@"TestNotification3" object:nil];

    [[NSRunLoop currentRunLoop] run];
    [pool release];
    return NULL;
}

@interface WorkerThread : NSObject 
{
@public    
    void* (*routine)(void*);
    void* arg;
}
- (void)startThread;
@end

@implementation WorkerThread
- (void)startThread
{
    routine(arg);
}
@end


int main2() {
    
    NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
    [NSApplication sharedApplication];

    for (int i = 0; i < NUM_THREADS; i++) {
        for (int j = 0; i < NUM_THREADS; i++) {
            ports1[i][j] = nil;
            ports2[i][j] = nil;
        }
    }

    for (int i = 0; i < NUM_THREADS; i++) {
        WorkerThread *thread = [[WorkerThread alloc] init];
        thread->routine = thread_routine;
        thread->arg = (void*)i;
        [NSThread detachNewThreadSelector:@selector(startThread) toTarget:thread withObject:nil];
    }

    sleep(2);

    NSNotificationCenter* center = [NSNotificationCenter defaultCenter];
    NSNotification* notification3 = [NSNotification notificationWithName:@"TestNotification3" object:nil];
    [center postNotification:notification3];
    sleep(2);

    NSNotification* notification2 = [NSNotification notificationWithName:@"TestNotification2" object:nil];
    [center postNotification:notification2];
    sleep(2);

    NSNotification* notification1 = [NSNotification notificationWithName:@"TestNotification1" object:nil];
    [center postNotification:notification1];

    [[NSRunLoop currentRunLoop] run];

    [pool release];
    return 0;
}

int main()
{
    int result = 0;

    NS_DURING
    {
        result = main2();
    }
    NS_HANDLER
    {
        fprintf(stderr, "objective-c exception [%s]\n", [[localException name] cString]);
    }
    NS_ENDHANDLER

        return 1;
}