Use this class to create a pool of processes that can use the db (in parallel).
Class that extends multiprocessing.pool to allow to use the db in the sub processes. It clears the db connection before and after the pool.
:param Pool: description :type Pool: type
Initialize self. See help(type(self)) for accurate signature.
Any
Any
tuple
- ()
Any
Any
Equivalent of func(*args, **kwds)
.
Pool must be running.
Any
dict
- {}
Asynchronous version of apply()
method.
Any
dict
- {}
Any
Any
Set
Equivalent of map()
-- can be MUCH slower than Pool.map()
.
Any
Any
int
- 1
Like imap()
method but ordering of results is arbitrary.
Any
Any
int
- 1
Apply func
to each element in iterable
, collecting the results
in a list that is returned.
Any
Any
Any
Asynchronous version of map()
method.
Any
Any
Any
Any
Any
Like map()
method but the elements of the iterable
are expected to
be iterables as well and will be unpacked as arguments. Hence
func
and (a, b) becomes func(a, b).
Any
Any
Any
Asynchronous version of starmap()
method.
Any
Any
Any
Any
Any
Any
Any