java线程间的通信和线程池 |
您所在的位置：网站首页 › java线程之间的通信 › java线程间的通信和线程池 |
java线程间的通信和线程池
|
出现的问题：并发的线程数量很多，且每个线程都是执行一个时间很短的任务就结束了，这样频繁创建线程会大大降低系统的效率
解决办法：线程池 线程池-->集合（ArrayList、HashSet、LinkedList,HashMap） 当程序第一次启动的时候，创建多个线程，保存到一个集合中 当我们想要使用线程的时候，就可以从集合中取出来线程使用 list.remove（线程只能被一个任务使用） Thread t=link.remove(); 使用完毕后归还线程给线程池 list.add(t);
jdk1.5后内置了线程池可以直接使用
原理图：
好处： 1、降低资源消耗 2、提高响应速度 3、提高线程的可管理性
线程池的使用 java.util.concurrnet.Executors 生产线程池的工厂类Executors 其中有一个方法 static ExecutorService newFixedPool(int nThreads) 创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程 参数：int nThreads：创建线程池中包含的线程数量 返回值：ExecutorService接口的实现类对象，我们可以使用ExecutorService接口接收（面向接口编程）
java.util.concurrent.ExecutorService:线程池接口 用来从线程池中获取线程，调用start方法，执行线程任务 里面有一个submit(Runnable task)提交一个Runnable任务用于执行 关闭/销毁线程池的方法shutdown()
线程池的使用步骤： 1、使用线程池的工厂类Executors里提供的静态方法newFixedThreadPool生产一个指定线程数量的线程池 2、创建一个类，实现Runnable接口，重写run方法，设置线程任务 3、调用ExecutorService中的方法submit，传递线程任务（实现类），开启线程，执行run方法 4、调用ExecutorService中的方法shutdown销毁线程池（不建议）
public static void main(String[] args) { //创建两个线程 ExecutorService es=Executors.newFixedThreadPool(2); es.submit(new RunnableImpl()); es.submit(new RunnableImpl()); es.submit(new RunnableImpl()); //线程池会一直开启，使用完了线程，会自动把线程归还给线程池，线程可以继续使用 es.shutdown(); } Runnable接口实现类： @Override public void run() { System.out.println(Thread.currentThread().getName()+"创建了一个新的线程执行"); }
效果：
|
【本文地址】