/**
 * Constructs a new {@code Thread}.  Implementations may also initialize
 * priority, name, daemon status, {@code ThreadGroup}, etc.
 *
 * @param r a runnable to be executed by new thread instance
 

 * @return constructed thread, or {@code null} if the request to
 *         create a thread is rejected
 */
Thread newThread(Runnable r);

package com.winwill.thread;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

/**
 

 * @author qifuguang
 * @date 15/8/11 20:28
 */
public class MyThreadFactoryTest implements ThreadFactory {
    private final AtomicInteger count = new AtomicInteger(0);

    public Thread newThread(Runnable r) {
        int c = count.incrementAndGet();
        Thread t = new Thread(r);
        t.setName("test_thread_no." + c);
        System.out.println("Create new thread, thread name: " + t.getName());
        return t;
    }

    public static void main(String[] args) throws Exception {
        ExecutorService service = Executors.newFixedThreadPool(5, new MyThreadFactoryTest());
        for (int i = 0; i < 5; i++) {
            service.submit(new Runnable() {
                public void run() {
                    System.out.println("Start execute...");
                }
            });
        }
    }
}

/**
    * The default thread factory
    */
   static class DefaultThreadFactory implements ThreadFactory {
       private static final AtomicInteger poolNumber = new AtomicInteger(1);
       private final ThreadGroup group;
       private final AtomicInteger threadNumber = new AtomicInteger(1);
       private final String namePrefix;

       DefaultThreadFactory() {
           SecurityManager s = System.getSecurityManager();
           group = (s != null) ? s.getThreadGroup() :
                                 Thread.currentThread().getThreadGroup();
           namePrefix = "pool-" +
                         poolNumber.getAndIncrement() +
                        "-thread-";
       }

       public Thread newThread(Runnable r) {
           Thread t = new Thread(group, r,
                                 namePrefix + threadNumber.getAndIncrement(),
                                 0);
           if (t.isDaemon())
               t.setDaemon(false);
           if (t.getPriority() != Thread.NORM_PRIORITY)
               t.setPriority(Thread.NORM_PRIORITY);
           return t;
       }
   }