线程池实例
线程池的好处:线程池里的每一个线程代码结束后,并不会死亡,而是再次回到线程池中成为空闲状态,等待下一个对象来使用。
如何实现线程的代码呢?
A:创建一个线程池对象,控制要创建几个线程对象。
public static ExecutorService newFixedThreadPool(int nThreads)
B:这种线程池的线程可以执行:
可以执行Runnable对象或者Callable对象代表的线程
做一个类实现Runnable接口。
C:调用如下方法即可
Future<?> submit(Runnable task)
<T> Future<T> submit(Callable<T> task)
D:我就要结束,可以吗? 可以。
1 package com.jt.thread.demo05; 2 3 import java.util.concurrent.ExecutorService; 4 import java.util.concurrent.Executors; 5 6 class MyRunnable implements Runnable { 7 @Override 8 public void run() { 9 for (int x = 0; x < 100; x++) { 10 System.out.println(Thread.currentThread().getName() + ":" + x); 11 } 12 } 13 } 14 15 public class ExecutorServiceDemo { 16 public static void main(String[] args) { 17 // 创建一个线程池对象,控制要创建几个线程对象。 18 // public static ExecutorService newFixedThreadPool(int nThreads) 19 ExecutorService pool = Executors.newFixedThreadPool(2); 20 21 // 可以执行Runnable对象或者Callable对象代表的线程 22 pool.submit(new MyRunnable()); 23 pool.submit(new MyRunnable()); 24 25 //结束线程池 26 pool.shutdown(); 27 } 28 }
System.out.println("线程池中线程数目:"+((ThreadPoolExecutor)pool).getPoolSize()+",队列中等待执行的任务数目:"+
((ThreadPoolExecutor)pool).getQueue().size()+",已执行玩别的任务数目:"+((ThreadPoolExecutor)pool).getCompletedTaskCount());