1. this.defaultAsyncSenderExecutor = new ThreadPoolExecutor(
    2.     Runtime.getRuntime().availableProcessors(),
    3.     Runtime.getRuntime().availableProcessors(),
    4.     1000 * 60,
    5.     TimeUnit.MILLISECONDS,
    6.     this.asyncSenderThreadPoolQueue,
    7.     new ThreadFactory() {
    8.         private AtomicInteger threadIndex = new AtomicInteger(0);
    10.         @Override
    11.         public Thread newThread(Runnable r) {
    12.             return new Thread(r, "AsyncSenderExecutor_" + this.threadIndex.incrementAndGet());
    13.         }
    14.     });