@@ -12,6 +12,9 @@ _T = TypeVar("_T")
12
12
class Empty (Exception ): ...
13
13
class Full (Exception ): ...
14
14
15
+ if sys .version_info >= (3 , 13 ):
16
+ class ShutDown (Exception ): ...
17
+
15
18
class Queue (Generic [_T ]):
16
19
maxsize : int
17
20
@@ -20,6 +23,8 @@ class Queue(Generic[_T]):
20
23
not_full : Condition # undocumented
21
24
all_tasks_done : Condition # undocumented
22
25
unfinished_tasks : int # undocumented
26
+ if sys .version_info >= (3 , 13 ):
27
+ is_shutdown : bool # undocumented
23
28
# Despite the fact that `queue` has `deque` type,
24
29
# we treat it as `Any` to allow different implementations in subtypes.
25
30
queue : Any # undocumented
@@ -29,6 +34,9 @@ class Queue(Generic[_T]):
29
34
def full (self ) -> bool : ...
30
35
def get (self , block : bool = True , timeout : float | None = None ) -> _T : ...
31
36
def get_nowait (self ) -> _T : ...
37
+ if sys .version_info >= (3 , 13 ):
38
+ def shutdown (self , immediate : bool = False ) -> None : ...
39
+
32
40
def _get (self ) -> _T : ...
33
41
def put (self , item : _T , block : bool = True , timeout : float | None = None ) -> None : ...
34
42
def put_nowait (self , item : _T ) -> None : ...
0 commit comments