package com.gh.threadpoor;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

 * 使用线程池

 * @author ganhang

 *

 */

public class ThreadPoorDemo {

    public static void main(String[] args) {

        //创建一个单线程的线程池

        ExecutorService es=Executors.newSingleThreadExecutor();

        //创建一个固定大小的线程池（2个）

        ExecutorService es1=Executors.newFixedThreadPool(2);

        //创建一个可缓存的线程池,保存线程60s再回收

        ExecutorService es2=Executors.newCachedThreadPool();

        //创建一个无限制大小的线程池，需要给定一个起始大小（最小的大小），但不会回收

        ExecutorService es3=Executors.newScheduledThreadPool(2);

        Mythread m1=new Mythread();

        Mythread m2=new Mythread();

        es.execute(m1);

        es.execute(m2);

    }

}

class Mythread implements Runnable{

    @Override

    public void run() {

        for(int i=0;i<10;i++){

            try {

                Thread.sleep(1000);

            } catch (InterruptedException e) {

                e.printStackTrace();

            }

            System.out.println(Thread.currentThread().getName()+"--"+i);

        }

    }

}