An idea for extending the blocking queue with predicates.