jacinle.concurrency.pool#

Classes

`Pool`
`TQDMPool`

Class Pool

class Pool[source]#

Bases: object

Process(*args, **kwargs)[source]#

Queue(*args, **kwargs)[source]#

__init__(nr_workers=None)[source]#

__new__(**kwargs)#

map(func, iterable, chunksize=1, sort=True, callback=None)[source]#

start()[source]#

terminate()[source]#

try_start()[source]#

Class TQDMPool

class TQDMPool[source]#

Bases: Pool

Process(*args, **kwargs)#

Queue(*args, **kwargs)#

__init__(nr_workers=None)#

__new__(**kwargs)#

map(func, iterable, chunksize=1, sort=True, total=None, desc='', callback=None, use_tqdm=True, update_interval=0.1, update_iters=1, **kwargs)[source]#

start()#

terminate()#

try_start()#