Concurrency, BlockingQueue not useable for simple usecase?