Queue() constructor - missing `maxsize` argument.

alex-petrenko / faster-fifo

Faster alternative to Python's multiprocessing.Queue (IPC FIFO queue)

MIT License

179 stars 29 forks source link

Queue() constructor - missing `maxsize` argument. #22

Closed folkien closed 1 year ago

folkien commented 3 years ago

Not fully compatible with standard Queue. Missing maxsize argument.

alex-petrenko commented 3 years ago

Indeed this should be implemented. Feel free to submit a PR!

github-actions[bot] commented 3 years ago

This issue is stale because it has been open for 30 days with no activity.

azmathmoosa commented 3 years ago

is there an alternative? need to set limit on max queue size in my application. if queue is full, i want the producer to drop data. its a video analytics application and I need to drop frames to keep up with processing demand.

alex-petrenko commented 3 years ago

Why not catch the Full exception that's raised when there's no more space in the queue? You can drop a frame every time the exception is raised