MCPcopy Create free account

hub / github.com/omnilib/aiomultiprocess / functions

Functions106 in github.com/omnilib/aiomultiprocess

↓ 16 callersMethodstart
Start the child process.
aiomultiprocess/core.py:154
↓ 13 callersMethodis_alive
Is child process running.
aiomultiprocess/core.py:174
↓ 10 callersMethodjoin
Wait for the process to finish execution without blocking the main thread.
aiomultiprocess/core.py:158
↓ 8 callersFunctionget_context
Get the current active global context.
aiomultiprocess/core.py:59
↓ 5 callersMethodapply
Run a single coroutine on the pool.
aiomultiprocess/pool.py:316
↓ 5 callersMethodmap
Run a coroutine once for each item in the iterable.
aiomultiprocess/pool.py:333
↓ 4 callersMethodjoin
Wait for the pool to finish gracefully.
aiomultiprocess/pool.py:374
↓ 4 callersMethodstarmap
Run a coroutine once for each sequence of items in the iterable.
aiomultiprocess/pool.py:346
↓ 3 callersMethodclose
Clean up child process once finished.
aiomultiprocess/core.py:209
↓ 3 callersMethodqueue_work
Add a new work item to the outgoing queue. :meta private:
aiomultiprocess/pool.py:264
↓ 3 callersMethodregister_process
(self, qid: QueueID)
aiomultiprocess/scheduler.py:69
↓ 3 callersMethodregister_queue
(self, tx: Queue)
aiomultiprocess/scheduler.py:66
↓ 3 callersMethodresults
Wait for all tasks to complete, and return results, preserving order. :meta private:
aiomultiprocess/pool.py:294
↓ 3 callersMethodschedule_task
( self, _task_id: TaskID, _func: Callable[..., Awaitable[R]], _args: Sequence[
aiomultiprocess/scheduler.py:73
↓ 3 callersMethodterminate
No running by the pool!
aiomultiprocess/pool.py:366
↓ 2 callersMethodclose
Close the pool to new visitors.
aiomultiprocess/pool.py:359
↓ 2 callersMethodcreate_worker
Create a worker process attached to the given transmit and receive queues. :meta private:
aiomultiprocess/pool.py:244
↓ 2 callersMethodjoin
Wait for the worker to finish, and return the final result.
aiomultiprocess/core.py:233
↓ 2 callersMethodkill
Send SIGKILL to child process.
aiomultiprocess/core.py:205
↓ 1 callersMethod__init__
( self, processes: Optional[int] = None, initializer: Optional[Callable[..., None]] =
aiomultiprocess/pool.py:151
↓ 1 callersMethodcomplete_task
Notify the scheduler that a task has been completed.
aiomultiprocess/scheduler.py:45
↓ 1 callersMethodfinish_work
Mark work items as completed. :meta private:
aiomultiprocess/pool.py:283
↓ 1 callersFunctionget_manager
Return a singleton shared manager.
aiomultiprocess/core.py:28
↓ 1 callersMethodinit
Create the initial mapping of processes and queues. :meta private:
aiomultiprocess/pool.py:198
↓ 1 callersMethodloop
Maintain the pool of workers while open. :meta private:
aiomultiprocess/pool.py:217
↓ 1 callersFunctionmapper
(value)
aiomultiprocess/tests/base.py:25
↓ 1 callersMethodregister_process
Notify the scheduler when a process is assigned to a queue. This should be used for determining weights for the scheduler. I
aiomultiprocess/scheduler.py:19
↓ 1 callersMethodregister_queue
Notify the scheduler when the pool creates a new transmit queue.
aiomultiprocess/scheduler.py:13
↓ 1 callersMethodresult
Easy access to the resulting value from the coroutine.
aiomultiprocess/core.py:239
↓ 1 callersMethodresults
Wait for all results and return them as a sequence
aiomultiprocess/pool.py:134
↓ 1 callersMethodresults_generator
Return results one-by-one as they are ready
aiomultiprocess/pool.py:142
↓ 1 callersMethodschedule_task
Given a task, return a queue ID that it should be sent to. `func`, `args` and `kwargs` are just the exact same arguments tha
aiomultiprocess/scheduler.py:28
↓ 1 callersFunctionset_start_method
Set the start method and context used for future processes/pools. When given no parameters (`set_context()`), will default to using the "spa
aiomultiprocess/core.py:37
↓ 1 callersMethodterminate
Send SIGTERM to child process.
aiomultiprocess/core.py:198
Method__aenter__
Enable `async with Pool() as pool` usage.
aiomultiprocess/pool.py:189
Method__aexit__
Automatically terminate the pool when falling out of scope.
aiomultiprocess/pool.py:193
Method__aiter__
Return results one-by-one as they are ready
aiomultiprocess/pool.py:138
Method__await__
Enable awaiting of the process result by chaining to `start()` & `join()`.
aiomultiprocess/core.py:125
Method__await__
Wait for all results and return them as a sequence
aiomultiprocess/pool.py:130
Method__enter__
(self)
aiomultiprocess/tests/perf.py:33
Method__exit__
(self, *args)
aiomultiprocess/tests/perf.py:37
Method__init__
( self, group: None = None, target: Optional[Callable] = None, name: Optional[
aiomultiprocess/core.py:83
Method__init__
(self, *args, **kwargs)
aiomultiprocess/core.py:217
Method__init__
(self)
aiomultiprocess/scheduler.py:60
Method__init__
( self, tx: Queue, rx: Queue, ttl: int = MAX_TASKS_PER_CHILD, concurre
aiomultiprocess/pool.py:47
Method__init__
(self, pool: "Pool", task_ids: Sequence[TaskID])
aiomultiprocess/pool.py:126
Method__init__
(self)
aiomultiprocess/tests/perf.py:29
Functionasync_test
(fn)
aiomultiprocess/tests/base.py:56
Functioncheck_uvloop
()
aiomultiprocess/tests/pool.py:14
Methodcomplete_task
(self, _task_id: TaskID)
aiomultiprocess/scheduler.py:82
Methoddaemon
Should child process be daemon.
aiomultiprocess/core.py:179
Functiondo_nothing
()
aiomultiprocess/tests/base.py:12
Methodexitcode
Exit code from child process, or None if still running.
aiomultiprocess/core.py:194
Functionget_dummy_constant
()
aiomultiprocess/tests/base.py:43
Functioninitializer
(value)
aiomultiprocess/tests/base.py:36
Methodinline
(x)
aiomultiprocess/tests/core.py:160
Methodname
Child process name.
aiomultiprocess/core.py:170
Functionnot_implemented
Default function to call when none given.
aiomultiprocess/core.py:75
Functionperf_test
(fn)
aiomultiprocess/tests/base.py:65
Methodpid
Process ID of child, or None if not started.
aiomultiprocess/core.py:189
Functionraise_fn
()
aiomultiprocess/tests/base.py:47
Methodresult
(self)
aiomultiprocess/tests/perf.py:41
Methodrun
Pick up work, execute work, return results, rinse, repeat.
aiomultiprocess/pool.py:71
Methodrun_async
Initialize the child process and event loop, then execute the coroutine.
aiomultiprocess/core.py:133
Methodrun_async
Initialize the child process and event loop, then execute the coroutine.
aiomultiprocess/core.py:222
MethodsetUp
(self)
aiomultiprocess/tests/core.py:23
Functionset_context
Set the start method and context used for future processes/pools. [DEPRECATED] Retained for backwards compatibility, and to retain prior beh
aiomultiprocess/core.py:65
Functionsleepy
(durations)
aiomultiprocess/tests/perf.py:45
Functionsleepy
()
aiomultiprocess/tests/base.py:20
Functionstarmapper
(*values)
aiomultiprocess/tests/base.py:29
Functionterminate
(process)
aiomultiprocess/tests/base.py:51
Methodtest_async_initializer
(self)
aiomultiprocess/tests/core.py:215
Methodtest_initializer
(self)
aiomultiprocess/tests/core.py:205
Methodtest_not_implemented
(self)
aiomultiprocess/tests/core.py:236
Methodtest_pool
(self)
aiomultiprocess/tests/pool.py:78
Methodtest_pool_args
(self)
aiomultiprocess/tests/pool.py:149
Methodtest_pool_closed
(self)
aiomultiprocess/tests/pool.py:154
Methodtest_pool_concurrency
(self)
aiomultiprocess/tests/perf.py:55
Methodtest_pool_early_join
(self)
aiomultiprocess/tests/pool.py:170
Methodtest_pool_exception
(self)
aiomultiprocess/tests/pool.py:131
Methodtest_pool_exception_handler
(self)
aiomultiprocess/tests/pool.py:137
Methodtest_pool_map
(self)
aiomultiprocess/tests/pool.py:94
Methodtest_pool_starmap
(self)
aiomultiprocess/tests/pool.py:112
Methodtest_pool_uvloop
(self)
aiomultiprocess/tests/pool.py:176
Methodtest_pool_worker_exceptions
(self)
aiomultiprocess/tests/pool.py:57
Methodtest_pool_worker_max_tasks
(self)
aiomultiprocess/tests/pool.py:23
Methodtest_pool_worker_stop
(self)
aiomultiprocess/tests/pool.py:38
Methodtest_process
(self)
aiomultiprocess/tests/core.py:28
Methodtest_process_await
(self)
aiomultiprocess/tests/core.py:40
Methodtest_process_close
(self)
aiomultiprocess/tests/core.py:102
Methodtest_process_daemon
(self)
aiomultiprocess/tests/core.py:64
Methodtest_process_join
(self)
aiomultiprocess/tests/core.py:53
Methodtest_process_kill
(self)
aiomultiprocess/tests/core.py:87
Methodtest_process_terminate
(self)
aiomultiprocess/tests/core.py:76
Methodtest_process_timeout
(self)
aiomultiprocess/tests/core.py:125
Methodtest_raise
(self)
aiomultiprocess/tests/core.py:221
Methodtest_roundrobin_scheduler_one
(self)
aiomultiprocess/tests/scheduler.py:10
Methodtest_roundrobin_scheduler_two
(self)
aiomultiprocess/tests/scheduler.py:18
Methodtest_set_context
(self, ssm_mock)
aiomultiprocess/tests/core.py:193
Methodtest_set_start_method
(self)
aiomultiprocess/tests/core.py:171
next →1–100 of 106, ranked by callers