Message153785
Here is an initial implementation. Differences from threading.Barrier:
- I have not implemented reset().
- wait() returns 0 or -1. One thread returns 0, the remainder return -1.
This is different to threading.Barrier where each of the N threads
returns a unique index in range(N).
- I added an "action_args" parameter to the constructor. This is a tuple
which provides argument to the "action" callback. (This is because closures
are not picklable, making no-argument callbacks rather limiting for
multiprocessing.) |
|
Date |
User |
Action |
Args |
2012-02-20 17:16:40 | sbt | set | recipients:
+ sbt, anacrolix |
2012-02-20 17:16:40 | sbt | set | messageid: <1329758200.38.0.396713097749.issue14059@psf.upfronthosting.co.za> |
2012-02-20 17:16:39 | sbt | link | issue14059 messages |
2012-02-20 17:16:39 | sbt | create | |
|