我想创建一个阻塞队列,基于自定义规则而不是队列中的项数来阻塞生产者。
例如:
生产者生成一些文件并放入队列中。消费者在进行一些分析后将它们传输到特定位置。
对于上述情况,如果队列中的总文件大小达到某个阈值,我希望生产者等待生成新文件。如果总大小未超过阈值,则队列可以接受任意数量的文件。
例如:
生产者生成一些文件并放入队列中。消费者在进行一些分析后将它们传输到特定位置。
对于上述情况,如果队列中的总文件大小达到某个阈值,我希望生产者等待生成新文件。如果总大小未超过阈值,则队列可以接受任意数量的文件。