1 from typing import Any, Optional, List, Type
\r
9 from multiprocessing import TimeoutError, cpu_count
\r
10 from multiprocessing.dummy.connection import Pipe
\r
11 from threading import Lock, RLock, Semaphore, BoundedSemaphore
\r
12 from threading import Event
\r
13 from Queue import 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: bool
\r
21 def __init__(self, group=..., target=..., name=..., args=..., kwargs=...) -> None: ...
\r
23 def exitcode(self) -> Optional[int]: ...
\r
26 Process = DummyProcess
\r
28 # This should be threading._Condition but threading.pyi exports it as Condition
\r
29 class Condition(threading.Condition):
\r
30 notify_all = ... # type: Any
\r
32 class Namespace(object):
\r
33 def __init__(self, **kwds) -> None: ...
\r
35 class Value(object):
\r
36 _typecode = ... # type: Any
\r
37 _value = ... # type: Any
\r
38 value = ... # type: Any
\r
39 def __init__(self, typecode, value, lock=...) -> None: ...
\r
40 def _get(self) -> Any: ...
\r
41 def _set(self, value) -> None: ...
\r
43 JoinableQueue = Queue
\r
45 def Array(typecode, sequence, lock=...) -> array.array: ...
\r
46 def Manager() -> Any: ...
\r
47 def Pool(processes=..., initializer=..., initargs=...) -> Any: ...
\r
48 def active_children() -> List: ...
\r
49 def current_process() -> threading.Thread: ...
\r
50 def freeze_support() -> None: ...
\r
51 def shutdown() -> None: ...
\r