replace ConcurrentArrayBlockingQueue with java.concurrent queues