Java线程池代码实现

package com.fgy.demo07;

public class RunnableImpl implements Runnable {
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "创建了一个新的线程");
    }
}

package com.fgy.demo07;

public class ExtendsThread extends Thread {
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "创建了一个新的线程");
    }
}

package com.fgy.demo07;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Demo01ThreadTool {
    public static void main(String[] args) {
        ExecutorService pool = Executors.newFixedThreadPool(3); // 创建线程池，初始化有三个线程
        pool.submit(new RunnableImpl());
        pool.submit(new Runnable(){
            @Override
            public void run() {
                System.out.println(Thread.currentThread().getName() + "创建了一个新的线程");
            }
        });
        pool.submit(new Thread(){
            @Override
            public void run() {
                System.out.println(getName() + "创建了一个新的线程");
            }
        });
        pool.submit(new ExtendsThread()); // pool-1-thread-2创建了一个新的线程
                                          // Thread-0创建了一个新的线程
                                          // pool-1-thread-3创建了一个新的线程
                                          // pool-1-thread-1创建了一个新的线程

        // 销毁线程池
        pool.shutdown();
    }
}