假如写网络编程的程序,socket编程就是响应客户编程的服务端。
public class ThreadPool { public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(80); while (true){ Socket socket = serverSocket.accept(); Runnable task = new Runnable() { @Override public void run() { handleRequest(socket); } }; new Thread(task).start(); } } private static void handleRequest(Socket socket) { } }
这样做,每来一个就创建一个线程,会出现很多问题的。java虚拟机就挂掉了,内存溢出。
资源消耗得不到限制,并不能控制线程的数量。
//Executor 线程池
创建线程池
Executor executor = Executors.newFixedThreadPool(100);
拥有100线程的线程池。
Executor executor1 = Executors.newSingleThreadExecutor();
池子里,永远只有一个线程。平常如果new一个线程,挂掉了就没有了。
single这个如果被占用了,就阻塞这里等着,如果有异常了,就拿一条新的线程。
Executor executor2 = Executors.newCachedThreadPool();
这个是缓冲线程池,不知道有多少个线程。来一个创建一个,来一个创建一个。没有上限的。
Executor是个接口,ExecutorService是个子类。
线程池的任务丢进去是不可控的,什么时间关闭,如果executor没有运行完,jvm是不可能关闭的,除非你强行关闭电源。
ExecutorService提供了关闭的方法。
List<Runnable> shutdownNow(); void shutdown(); boolean isTerminated();
线程池有三种状态:
1,运行状态。running
2,关闭状态。shutdown状态,不是立即终止,停止接受新的任务,但是等待提交的任务完成。
3,终止状态。什么任务都完成了。把线程池掐掉。
shutdownNow返回还没有执行完的任务的线程。isTerminated是所有线程都死掉了。
tomcat源码用的exector,解析http协议。
public class ThreadPool { static ExecutorService executor = Executors.newFixedThreadPool(100); //Executor 线程池 public static void main(String[] args) throws IOException { ServerSocket serverSocket = new ServerSocket(80); while (!executor.isShutdown()){ Socket socket = serverSocket.accept(); try { executor.execute(new Runnable() { @Override public void run() { handleRequest(socket); } }); //RejectedExecutionException 拒绝执行任务异常 } catch (RejectedExecutionException e) { if (!executor.isShutdown()){ System.out.println("线程池接受任务被拒绝"); throw e; } } } } public void stop(){ executor.shutdown(); } private static void handleRequest(Socket socket) { } }
Executors.newScheduledThreadPool();
java的定时任务的执行,可调度的定时任务的执行。
public class Shedule { private static long start; private static ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2); public static void main(String[] args) { TimerTask task = new TimerTask() { @Override public void run() { System.out.println(System.currentTimeMillis()-start); try{ Thread.sleep(3000); }catch (InterruptedException e){ e.printStackTrace(); } } }; TimerTask task1 = new TimerTask(){ @Override public void run() { System.out.println(System.currentTimeMillis()-start); } }; Timer timer = new Timer(); start = System.currentTimeMillis(); //启动一个调度任务,delay延迟毫毛单位 timer.schedule(task,1000); timer.schedule(task1,3000); } }
用Timer,线程之间是相互干扰的。Timer是个单线程。
public class Shedule { private static long start; private static ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2); public static void main(String[] args) { TimerTask task = new TimerTask() { @Override public void run() { System.out.println(System.currentTimeMillis()-start); try{ Thread.sleep(3000); }catch (InterruptedException e){ e.printStackTrace(); } } }; TimerTask task1 = new TimerTask(){ @Override public void run() { System.out.println(System.currentTimeMillis()-start); } }; // Timer timer = new Timer(); start = System.currentTimeMillis(); //启动一个调度任务,delay延迟毫毛单位 // timer.schedule(task,1000); // timer.schedule(task1,3000); executorService.schedule(task,1000, TimeUnit.MILLISECONDS); executorService.schedule(task,3000, TimeUnit.MILLISECONDS); } }
如果第一个线程异常了,那么就阻塞在这了。
public class Shedule { private static long start; private static ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2); public static void main(String[] args) { TimerTask task = new TimerTask() { @Override public void run() { throw new RuntimeException(); } }; TimerTask task1 = new TimerTask(){ @Override public void run() { System.out.println(System.currentTimeMillis()-start); } }; Timer timer = new Timer(); start = System.currentTimeMillis(); //启动一个调度任务,delay延迟毫毛单位 timer.schedule(task,1000); timer.schedule(task1,3000); // executorService.schedule(task,1000, TimeUnit.MILLISECONDS); // executorService.schedule(task,3000, TimeUnit.MILLISECONDS); } }
executorService用的是相对时间,不是系统时间。
用那些pool,实际上底层返回的是ThreadPoolExecutor返回的。
public ThreadPoolExecutor(int corePoolSize,//线程数量 int maximumPoolSize,//最大的线程数量 long keepAliveTime,//线程活跃的时间是多少 TimeUnit unit,//时间单位 BlockingQueue<Runnable> workQueue//里面装的是Runnable 并发容器 workQueue工作队列) { this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, Executors.defaultThreadFactory(), defaultHandler); }
executor接口,关闭不是很好关闭。
Executors是工具类,可以搞线程池这些东西。这里面的方法最终弄的是ThreadPoolExecutor。都可以指定的。