| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
| |
task.min_count, to fix theoretical option for a deadlock in serial mode, and unnecessary blocking in async mode
|
| |
|
|
|
|
| |
multiple connected pools
Reduced waiting time in tests to make them complete faster
|
| |
|
|
| |
single task for now, but next up are dependent tasks
|
| |
|
|
| |
related to our channel closed flag, which is the only way not to block forever on read(0) channels which were closed by a thread 'in the meanwhile'
|
| |
|
|
| |
chunking test. Next up, actual async processing
|
| |
|
|
| |
including own tests, their design improved to prepare them for some specifics that would be needed for multiprocessing support
|
| |
|
|
|
|
|
| |
is handled by the task system
graph: implemented it including test according to the pools requirements
pool: implemented set_pool_size
|
| |
|
|
| |
while going. Tests will be written soon for verification, its still quite theoretical
|
|
|
going on. The default implementation uses threads, which ends up being nothing more than async, as they are all locked down by internal and the global interpreter lock
|