elasticsearch源码学习（一）

1. es中的线程命名

public class Netty4Transport {
    public static void main(String[] args) {
        ExecutorService executorService = new ThreadPoolExecutor(
                        3, 3, 3, TimeUnit.SECONDS, new linkedBlockingQueue(), EsExecutors.daemonThreadFactory("elasticsearch[transport_worker]"));
        for (int i = 0; i < 10; i++) {
            executorService.execute(new Runnable() {
                @Override
                public void run() {
                    System.out.println(Thread.currentThread().getName());
                }
            });
        }

    }
}

class EsExecutors {

    public static ThreadFactory daemonThreadFactory(String namePrefix) {
        return new EsThreadFactory(namePrefix);
    }

    static class EsThreadFactory implements ThreadFactory {

        final ThreadGroup group;
        final AtomicInteger threadNumber = new AtomicInteger(1);
        final String namePrefix;

        EsThreadFactory(String namePrefix) {
            this.namePrefix = namePrefix;
            SecurityManager s = System.getSecurityManager();
            group = (s != null) ? s.getThreadGroup() : Thread.currentThread().getThreadGroup();
        }

        @Override
        public Thread newThread(Runnable r) {
            Thread t = new Thread(group, r, namePrefix + "[T#" + threadNumber.getAndIncrement() + "]", 0);
            t.setDaemon(true);
            return t;
        }
    }
}