Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/omnilib/aiomultiprocess
/ functions
Functions
106 in github.com/omnilib/aiomultiprocess
⨍
Functions
106
◇
Types & classes
14
↳
Endpoints
1
↓ 16 callers
Method
start
Start the child process.
aiomultiprocess/core.py:154
↓ 13 callers
Method
is_alive
Is child process running.
aiomultiprocess/core.py:174
↓ 10 callers
Method
join
Wait for the process to finish execution without blocking the main thread.
aiomultiprocess/core.py:158
↓ 8 callers
Function
get_context
Get the current active global context.
aiomultiprocess/core.py:59
↓ 5 callers
Method
apply
Run a single coroutine on the pool.
aiomultiprocess/pool.py:316
↓ 5 callers
Method
map
Run a coroutine once for each item in the iterable.
aiomultiprocess/pool.py:333
↓ 4 callers
Method
join
Wait for the pool to finish gracefully.
aiomultiprocess/pool.py:374
↓ 4 callers
Method
starmap
Run a coroutine once for each sequence of items in the iterable.
aiomultiprocess/pool.py:346
↓ 3 callers
Method
close
Clean up child process once finished.
aiomultiprocess/core.py:209
↓ 3 callers
Method
queue_work
Add a new work item to the outgoing queue. :meta private:
aiomultiprocess/pool.py:264
↓ 3 callers
Method
register_process
(self, qid: QueueID)
aiomultiprocess/scheduler.py:69
↓ 3 callers
Method
register_queue
(self, tx: Queue)
aiomultiprocess/scheduler.py:66
↓ 3 callers
Method
results
Wait for all tasks to complete, and return results, preserving order. :meta private:
aiomultiprocess/pool.py:294
↓ 3 callers
Method
schedule_task
( self, _task_id: TaskID, _func: Callable[..., Awaitable[R]], _args: Sequence[
aiomultiprocess/scheduler.py:73
↓ 3 callers
Method
terminate
No running by the pool!
aiomultiprocess/pool.py:366
↓ 2 callers
Method
close
Close the pool to new visitors.
aiomultiprocess/pool.py:359
↓ 2 callers
Method
create_worker
Create a worker process attached to the given transmit and receive queues. :meta private:
aiomultiprocess/pool.py:244
↓ 2 callers
Method
join
Wait for the worker to finish, and return the final result.
aiomultiprocess/core.py:233
↓ 2 callers
Method
kill
Send SIGKILL to child process.
aiomultiprocess/core.py:205
↓ 1 callers
Method
__init__
( self, processes: Optional[int] = None, initializer: Optional[Callable[..., None]] =
aiomultiprocess/pool.py:151
↓ 1 callers
Method
complete_task
Notify the scheduler that a task has been completed.
aiomultiprocess/scheduler.py:45
↓ 1 callers
Method
finish_work
Mark work items as completed. :meta private:
aiomultiprocess/pool.py:283
↓ 1 callers
Function
get_manager
Return a singleton shared manager.
aiomultiprocess/core.py:28
↓ 1 callers
Method
init
Create the initial mapping of processes and queues. :meta private:
aiomultiprocess/pool.py:198
↓ 1 callers
Method
loop
Maintain the pool of workers while open. :meta private:
aiomultiprocess/pool.py:217
↓ 1 callers
Function
mapper
(value)
aiomultiprocess/tests/base.py:25
↓ 1 callers
Method
register_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 callers
Method
register_queue
Notify the scheduler when the pool creates a new transmit queue.
aiomultiprocess/scheduler.py:13
↓ 1 callers
Method
result
Easy access to the resulting value from the coroutine.
aiomultiprocess/core.py:239
↓ 1 callers
Method
results
Wait for all results and return them as a sequence
aiomultiprocess/pool.py:134
↓ 1 callers
Method
results_generator
Return results one-by-one as they are ready
aiomultiprocess/pool.py:142
↓ 1 callers
Method
schedule_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 callers
Function
set_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 callers
Method
terminate
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
Function
async_test
(fn)
aiomultiprocess/tests/base.py:56
Function
check_uvloop
()
aiomultiprocess/tests/pool.py:14
Method
complete_task
(self, _task_id: TaskID)
aiomultiprocess/scheduler.py:82
Method
daemon
Should child process be daemon.
aiomultiprocess/core.py:179
Function
do_nothing
()
aiomultiprocess/tests/base.py:12
Method
exitcode
Exit code from child process, or None if still running.
aiomultiprocess/core.py:194
Function
get_dummy_constant
()
aiomultiprocess/tests/base.py:43
Function
initializer
(value)
aiomultiprocess/tests/base.py:36
Method
inline
(x)
aiomultiprocess/tests/core.py:160
Method
name
Child process name.
aiomultiprocess/core.py:170
Function
not_implemented
Default function to call when none given.
aiomultiprocess/core.py:75
Function
perf_test
(fn)
aiomultiprocess/tests/base.py:65
Method
pid
Process ID of child, or None if not started.
aiomultiprocess/core.py:189
Function
raise_fn
()
aiomultiprocess/tests/base.py:47
Method
result
(self)
aiomultiprocess/tests/perf.py:41
Method
run
Pick up work, execute work, return results, rinse, repeat.
aiomultiprocess/pool.py:71
Method
run_async
Initialize the child process and event loop, then execute the coroutine.
aiomultiprocess/core.py:133
Method
run_async
Initialize the child process and event loop, then execute the coroutine.
aiomultiprocess/core.py:222
Method
setUp
(self)
aiomultiprocess/tests/core.py:23
Function
set_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
Function
sleepy
(durations)
aiomultiprocess/tests/perf.py:45
Function
sleepy
()
aiomultiprocess/tests/base.py:20
Function
starmapper
(*values)
aiomultiprocess/tests/base.py:29
Function
terminate
(process)
aiomultiprocess/tests/base.py:51
Method
test_async_initializer
(self)
aiomultiprocess/tests/core.py:215
Method
test_initializer
(self)
aiomultiprocess/tests/core.py:205
Method
test_not_implemented
(self)
aiomultiprocess/tests/core.py:236
Method
test_pool
(self)
aiomultiprocess/tests/pool.py:78
Method
test_pool_args
(self)
aiomultiprocess/tests/pool.py:149
Method
test_pool_closed
(self)
aiomultiprocess/tests/pool.py:154
Method
test_pool_concurrency
(self)
aiomultiprocess/tests/perf.py:55
Method
test_pool_early_join
(self)
aiomultiprocess/tests/pool.py:170
Method
test_pool_exception
(self)
aiomultiprocess/tests/pool.py:131
Method
test_pool_exception_handler
(self)
aiomultiprocess/tests/pool.py:137
Method
test_pool_map
(self)
aiomultiprocess/tests/pool.py:94
Method
test_pool_starmap
(self)
aiomultiprocess/tests/pool.py:112
Method
test_pool_uvloop
(self)
aiomultiprocess/tests/pool.py:176
Method
test_pool_worker_exceptions
(self)
aiomultiprocess/tests/pool.py:57
Method
test_pool_worker_max_tasks
(self)
aiomultiprocess/tests/pool.py:23
Method
test_pool_worker_stop
(self)
aiomultiprocess/tests/pool.py:38
Method
test_process
(self)
aiomultiprocess/tests/core.py:28
Method
test_process_await
(self)
aiomultiprocess/tests/core.py:40
Method
test_process_close
(self)
aiomultiprocess/tests/core.py:102
Method
test_process_daemon
(self)
aiomultiprocess/tests/core.py:64
Method
test_process_join
(self)
aiomultiprocess/tests/core.py:53
Method
test_process_kill
(self)
aiomultiprocess/tests/core.py:87
Method
test_process_terminate
(self)
aiomultiprocess/tests/core.py:76
Method
test_process_timeout
(self)
aiomultiprocess/tests/core.py:125
Method
test_raise
(self)
aiomultiprocess/tests/core.py:221
Method
test_roundrobin_scheduler_one
(self)
aiomultiprocess/tests/scheduler.py:10
Method
test_roundrobin_scheduler_two
(self)
aiomultiprocess/tests/scheduler.py:18
Method
test_set_context
(self, ssm_mock)
aiomultiprocess/tests/core.py:193
Method
test_set_start_method
(self)
aiomultiprocess/tests/core.py:171
next →
1–100 of 106, ranked by callers