File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1748,7 +1748,8 @@ def test_queue_shutdown_count_pending_put(self):
17481748 # are pending.
17491749 self ._wait ()
17501750
1751- self .assertEqual (q ._sem_pending_putters .get_value (), n - size )
1751+ self .assertLessEqual (q ._sem_pending_putters .get_value (), n - size )
1752+ self .assertGreater (q ._sem_pending_putters .get_value (), 0 )
17521753 self .assertEqual (q ._sem_pending_getters .get_value (), 0 )
17531754 q .shutdown (immediate = False )
17541755 self .assertTrue (q ._is_shutdown ())
@@ -1821,8 +1822,8 @@ def test_queue_shutdown_count_pending_get(self):
18211822 # wait for all pending get processes to be blocked.
18221823 self ._wait ()
18231824
1824- self .assertTrue (q .empty () )
1825- self .assertEqual (q ._sem_pending_getters .get_value (), n )
1825+ self .assertLessEqual (q ._sem_pending_getters . get_value (), n )
1826+ self .assertGreater (q ._sem_pending_getters .get_value (), 0 )
18261827 self .assertEqual (q ._sem_pending_putters .get_value (), 0 )
18271828 q .shutdown (immediate = False )
18281829 self .assertTrue (q ._is_shutdown ())
You can’t perform that action at this time.
0 commit comments