1、首先了解一下线程的创建方式:Tread类用于创建线程new Thread(),使用时必须覆盖其方法,@Overide;一下创建九个线程,并输出任务数。代码如下public class TestThread { public static void main(String[] args) { for(int i=1;i<10;i++){ final int task=i; new Thread(new Runnable(){ @Override public void run(){ System.out.println("task:"+task); } }).start(); } } }

2、(1)newFixedThreadPool:创建一个固定线程数的线程池,并给线程分配任务创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。package testexcutor;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class TestExcutor { public static void main(String[] args) { ExecutorService fixThreadPool=Executors.newFixedThreadPool(5); for(int i=1;i<=5;i++){ final int task=i; fixThreadPool.execute(new Runnable(){ @Override public void run(){ for(int j=1;j<=5;j++){ System.out.println(Thread.currentThread().getName()+" "+"task:"+task+"times:"+j); } } }); } fixThreadPool.shutdown(); }}

3、(2)newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,缴赉丝别若无可回收,则新建线程。示例代码如下:package testexcutor;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;public class TestExcutor { public static void main(String[] args) { ExecutorService cashedThreadPool=Executors.newCachedThreadPool(); for(int i=1;i<=100;i++){ final int task=i; cashedThreadPool.execute(new Runnable(){ @Override public void run(){ for(int j=1;j<=5;j++){ System.out.println(Thread.currentThread().getName()+" "+"task:"+task+"times:"+j); } } }); } cashedThreadPool.shutdown(); } }创建100线程,但是由于有线程结束,所有可以回收再利用,不够使用时,再创建一个新的线程。

4、(3) newScheduledThreadPool创建一个定长线程池,支持定时及周期性任务执行。代码:import java.util.concurrent.Executors;import java.util.concurrent.ScheduledExecutorService;import java.util.concurrent.TimeUnit;public class TsetThreads { public static void main(String[] args) { ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5); scheduledThreadPool.schedule(new Runnable() { public void run() { System.out.println("delay 10 seconds"); } }, 10, TimeUnit.SECONDS); scheduledThreadPool.shutdown(); } }创建一个线程使其延迟10秒后执行


