Format: application/octet-stream
1 import sys
2 from types import FrameType, TracebackType
3 from typing import Any, Callable, Iterable, List, Mapping, Optional, Text, Type, TypeVar, Union
4
5 # TODO recursive type
6 _TF = Callable[[FrameType, str, Any], Optional[Callable[..., Any]]]
7
8 _PF = Callable[[FrameType, str, Any], None]
9 _T = TypeVar("_T")
10
11 __all__: List[str]
12
13 def active_count() -> int: ...
14
15 if sys.version_info < (3,):
16 def activeCount() -> int: ...
17
18 def current_thread() -> Thread: ...
19 def currentThread() -> Thread: ...
20
21 if sys.version_info >= (3,):
22 def get_ident() -> int: ...
23
24 def enumerate() -> List[Thread]: ...
25
26 if sys.version_info >= (3, 4):
27 def main_thread() -> Thread: ...
28
29 if sys.version_info >= (3, 8):
30 from _thread import get_native_id as get_native_id
31
32 def settrace(func: _TF) -> None: ...
33 def setprofile(func: Optional[_PF]) -> None: ...
34 def stack_size(size: int = ...) -> int: ...
35
36 if sys.version_info >= (3,):
37 TIMEOUT_MAX: float
38
39 class ThreadError(Exception): ...
40
41 class local(object):
42 def __getattribute__(self, name: str) -> Any: ...
43 def __setattr__(self, name: str, value: Any) -> None: ...
44 def __delattr__(self, name: str) -> None: ...
45
46 class Thread:
47 name: str
48 ident: Optional[int]
49 daemon: bool
50 if sys.version_info >= (3,):
51 def __init__(
52 self,
53 group: None = ...,
54 target: Optional[Callable[..., Any]] = ...,
55 name: Optional[str] = ...,
56 args: Iterable[Any] = ...,
57 kwargs: Mapping[str, Any] = ...,
58 *,
59 daemon: Optional[bool] = ...,
60 ) -> None: ...
61 else:
62 def __init__(
63 self,
64 group: None = ...,
65 target: Optional[Callable[..., Any]] = ...,
66 name: Optional[Text] = ...,
67 args: Iterable[Any] = ...,
68 kwargs: Mapping[Text, Any] = ...,
69 ) -> None: ...
70 def start(self) -> None: ...
71 def run(self) -> None: ...
72 def join(self, timeout: Optional[float] = ...) -> None: ...
73 def getName(self) -> str: ...
74 def setName(self, name: Text) -> None: ...
75 if sys.version_info >= (3, 8):
76 @property
77 def native_id(self) -> Optional[int]: ... # only available on some platforms
78 def is_alive(self) -> bool: ...
79 if sys.version_info < (3, 9):
80 def isAlive(self) -> bool: ...
81 def isDaemon(self) -> bool: ...
82 def setDaemon(self, daemonic: bool) -> None: ...
83
84 class _DummyThread(Thread): ...
85
86 class Lock:
87 def __init__(self) -> None: ...
88 def __enter__(self) -> bool: ...
89 def __exit__(
90 self, exc_type: Optional[Type[BaseException]], exc_val: Optional[BaseException], exc_tb: Optional[TracebackType]
91 ) -> Optional[bool]: ...
92 if sys.version_info >= (3,):
93 def acquire(self, blocking: bool = ..., timeout: float = ...) -> bool: ...
94 else:
95 def acquire(self, blocking: bool = ...) -> bool: ...
96 def release(self) -> None: ...
97 def locked(self) -> bool: ...
98
99 class _RLock:
100 def __init__(self) -> None: ...
101 def __enter__(self) -> bool: ...
102 def __exit__(
103 self, exc_type: Optional[Type[BaseException]], exc_val: Optional[BaseException], exc_tb: Optional[TracebackType]
104 ) -> Optional[bool]: ...
105 if sys.version_info >= (3,):
106 def acquire(self, blocking: bool = ..., timeout: float = ...) -> bool: ...
107 else:
108 def acquire(self, blocking: bool = ...) -> bool: ...
109 def release(self) -> None: ...
110
111 RLock = _RLock
112
113 class Condition:
114 def __init__(self, lock: Union[Lock, _RLock, None] = ...) -> None: ...
115 def __enter__(self) -> bool: ...
116 def __exit__(
117 self, exc_type: Optional[Type[BaseException]], exc_val: Optional[BaseException], exc_tb: Optional[TracebackType]
118 ) -> Optional[bool]: ...
119 if sys.version_info >= (3,):
120 def acquire(self, blocking: bool = ..., timeout: float = ...) -> bool: ...
121 else:
122 def acquire(self, blocking: bool = ...) -> bool: ...
123 def release(self) -> None: ...
124 def wait(self, timeout: Optional[float] = ...) -> bool: ...
125 if sys.version_info >= (3,):
126 def wait_for(self, predicate: Callable[[], _T], timeout: Optional[float] = ...) -> _T: ...
127 def notify(self, n: int = ...) -> None: ...
128 def notify_all(self) -> None: ...
129 def notifyAll(self) -> None: ...
130
131 class Semaphore:
132 def __init__(self, value: int = ...) -> None: ...
133 def __enter__(self) -> bool: ...
134 def __exit__(
135 self, exc_type: Optional[Type[BaseException]], exc_val: Optional[BaseException], exc_tb: Optional[TracebackType]
136 ) -> Optional[bool]: ...
137 if sys.version_info >= (3,):
138 def acquire(self, blocking: bool = ..., timeout: float = ...) -> bool: ...
139 else:
140 def acquire(self, blocking: bool = ...) -> bool: ...
141 if sys.version_info >= (3, 9):
142 def release(self, n: int = ...) -> None: ...
143 else:
144 def release(self) -> None: ...
145
146 class BoundedSemaphore(Semaphore): ...
147
148 class Event:
149 def __init__(self) -> None: ...
150 def is_set(self) -> bool: ...
151 if sys.version_info < (3,):
152 def isSet(self) -> bool: ...
153 def set(self) -> None: ...
154 def clear(self) -> None: ...
155 def wait(self, timeout: Optional[float] = ...) -> bool: ...
156
157 if sys.version_info >= (3, 8):
158 from _thread import _excepthook, _ExceptHookArgs
159
160 excepthook = _excepthook
161 ExceptHookArgs = _ExceptHookArgs
162
163 class Timer(Thread):
164 if sys.version_info >= (3,):
165 def __init__(
166 self,
167 interval: float,
168 function: Callable[..., Any],
169 args: Optional[Iterable[Any]] = ...,
170 kwargs: Optional[Mapping[str, Any]] = ...,
171 ) -> None: ...
172 else:
173 def __init__(
174 self, interval: float, function: Callable[..., Any], args: Iterable[Any] = ..., kwargs: Mapping[str, Any] = ...
175 ) -> None: ...
176 def cancel(self) -> None: ...
177
178 if sys.version_info >= (3,):
179 class Barrier:
180 parties: int
181 n_waiting: int
182 broken: bool
183 def __init__(self, parties: int, action: Optional[Callable[[], None]] = ..., timeout: Optional[float] = ...) -> None: ...
184 def wait(self, timeout: Optional[float] = ...) -> int: ...
185 def reset(self) -> None: ...
186 def abort(self) -> None: ...
187 class BrokenBarrierError(RuntimeError): ...
188