Message313855
The fix for the Queue._feeder does not properly handle the size of the Queue. This can lead to a situation where the Queue is considered as Full when it is empty. Here is a reproducing script:
```
import multiprocessing as mp
q = mp.Queue(1)
class FailPickle():
def __reduce__(self):
raise ValueError()
q.put(FailPickle())
print("Queue is full:", q.full())
q.put(0)
print(f"Got result: {q.get()}")
``` |
|
| Date |
User |
Action |
Args |
| 2018-03-15 06:36:54 | tomMoral | set | recipients:
+ tomMoral, pitrou, davin |
| 2018-03-15 06:36:54 | tomMoral | set | messageid: <[email protected]> |
| 2018-03-15 06:36:53 | tomMoral | link | issue33078 messages |
| 2018-03-15 06:36:52 | tomMoral | create | |
|