I just define a queue class which extends a blocking queue and overrides offer to call put and provide that to the executorservice.