1 from typing import Any, Optional, List, Type
\r
8 from .connection import Pipe
\r
9 from threading import Lock, RLock, Semaphore, BoundedSemaphore
\r
10 from threading import Event, Condition, Barrier
\r
11 from queue import Queue
\r
13 JoinableQueue = Queue
\r
16 class DummyProcess(threading.Thread):
\r
17 _children = ... # type: weakref.WeakKeyDictionary
\r
18 _parent = ... # type: threading.Thread
\r
19 _pid = ... # type: None
\r
20 _start_called = ... # type: int
\r
21 exitcode = ... # type: Optional[int]
\r
22 def __init__(self, group=..., target=..., name=..., args=..., kwargs=...) -> None: ...
\r
24 Process = DummyProcess
\r
26 class Namespace(object):
\r
27 def __init__(self, **kwds) -> None: ...
\r
29 class Value(object):
\r
30 _typecode = ... # type: Any
\r
31 _value = ... # type: Any
\r
32 value = ... # type: Any
\r
33 def __init__(self, typecode, value, lock=...) -> None: ...
\r
36 def Array(typecode, sequence, lock=...) -> array.array: ...
\r
37 def Manager() -> Any: ...
\r
38 def Pool(processes=..., initializer=..., initargs=...) -> Any: ...
\r
39 def active_children() -> List: ...
\r
40 def current_process() -> threading.Thread: ...
\r
41 def freeze_support() -> None: ...
\r
42 def shutdown() -> None: ...
\r