[Stackless] Fixed PAR (oops!)

[Tom Locke]

Ooops, scrap that - here's the code:

Tom.

def signalEnd(f, chan):
    f()
    chan.send(1)

def par(*funcs):
    taskEnd = stackless.channel()

    for f in funcs:
        stackless.tasklet(signalEnd)(f, taskEnd)

    stackless.schedule()
    
    count = len(funcs)
    while count > 0:
        taskEnd.receive()
        count -= 1




_______________________________________________
Stackless mailing list
Stackless at stackless.com
http://www.stackless.com/mailman/listinfo/stackless