- public TicketFinisher(BlockingQueue<Ticket<T>> queue,
- Set<PopListener<T>> listeners) {
- this.queue = queue;
- this.listeners = listeners;
- }
-
-
- @Override
- public void run() {
- try {
- Ticket<T> result = queue.take();
- for (PopListener<T> consumer : listeners) {
- consumer.onPop(result.getResult().get());
- }
- } catch (ExecutionException | InterruptedException e) {
- LOG.error(e.getMessage(), e);
- }
- }