pympipool.shared.executorbase

pympipool.shared.executorbase#

Functions

`cancel_items_in_queue`(que)	Cancel items which are still waiting in the queue.
`cloudpickle_register`([ind])	Cloudpickle can either pickle by value or pickle by reference.
`execute_parallel_tasks`(future_queue, cores, ...)	Execute a single tasks in parallel using the message passing interface (MPI).
`execute_separate_tasks`(future_queue, ...[, ...])	Execute a single tasks in parallel using the message passing interface (MPI).
`execute_tasks_with_dependencies`(...[, ...])	Resolve the dependencies of multiple tasks, by analysing which task requires concurrent.future.Futures objects from other tasks.

Classes