CountDownLatch blockLatch = new CountDownLatch( 1 );
executor = new ThreadPoolExecutor( 1, 1, 0, TimeUnit.SECONDS,
- ExecutorServiceUtil.offerFailingBlockingQueue( new LinkedBlockingQueue<Runnable>() ) );
+ ExecutorServiceUtil.offerFailingBlockingQueue(new LinkedBlockingQueue<>() ) );
CountingRejectedExecutionHandler countingHandler =
CountingRejectedExecutionHandler.newCallerRunsPolicy();
CountDownLatch blockLatch = new CountDownLatch( 1 );
executor = new ThreadPoolExecutor( 1, 1, 0, TimeUnit.SECONDS,
- ExecutorServiceUtil.offerFailingBlockingQueue( new LinkedBlockingQueue<Runnable>() ) );
+ ExecutorServiceUtil.offerFailingBlockingQueue(new LinkedBlockingQueue<>() ) );
CountingRejectedExecutionHandler countingHandler =
CountingRejectedExecutionHandler.newAbortPolicy();