加入收藏 | 设为首页 | 会员中心 | 我要投稿 核心网 (https://www.hxwgxz.com/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 建站 > 正文

Java线程池实现原理与技术,看这一篇就够了

发布时间:2019-04-01 15:09:41 所属栏目:建站 来源:程序员柯南
导读:01.无限制线程的缺点 多线程的软件设计方法确实可以最大限度地发挥多核处理器的计算能力,提高生产系统的吞吐量和性能。但是,若不加控制和管理的随意使用线程,对系统的性能反而会产生不利的影响。 一种最为简单的线程创建和回收的方法类似如下: newThre

关于ThreadPoolExecutor ,前面第3节已经详细叙述。ScheduledThreadPoolExecutor 也是ExecutorService接口的实现类,可以在给定的延迟后运行命令,或者定期执行命令。ScheduledThreadPoolExecutor 比 Timer 更灵活,功能更强大。

4.4 Future与FutureTask

上面的示例中使用 execute() 方法提交任务,,用于提交不需要返回值的任务。如果我们需要获取执行任务之后的返回值,可以使用submit()方法。

示例代码:

  1. public static void main(String[] args) throws InterruptedException, ExecutionException { 
  2.         //新建一个线程池 
  3.         ExecutorService executor = Executors.newCachedThreadPool(); 
  4.         List<Future> futureList = new Vector<>(); 
  5.         //在其它线程中执行100次下列方法 
  6.         for (int i = 0; i < 100; i++) { 
  7.             futureList.add(executor.submit(new Callable<String>() { 
  8.                 @Override 
  9.                 public String call() throws Exception { 
  10.                     return Thread.currentThread().getName()+" "+System.currentTimeMillis()+" "; 
  11.                 } 
  12.             })); 
  13.         } 
  14.         for (int i = 0;i<futureList.size();i++){ 
  15.             Object o = futureList.get(i).get(); 
  16.             System.out.println(o.toString()+i); 
  17.         } 
  18.         executor.shutdown(); 
  19.     } 

运行结果:

  1. ... 
  2. pool-1-thread-11 1537872778612 96 
  3. pool-1-thread-11 1537872778613 97 
  4. pool-1-thread-10 1537872778613 98 
  5. pool-1-thread-10 1537872778613 99 

到这里,就不得不提Future接口与FutureTask实现类,它们代表异步计算的结果。

  1. Future<T> submit(Callable<T> task) 
  2. Future<?> submit(Runnable task); 
  3. Future<T> submit(Runnable task, T result); 

当我们submit()提交后,会返回一个Future对象,到JDK1.8,返回的实际是FutureTask实现类。submit() 方法支持 Runnable 或 Callable 类型的参数。Runnable 接口 和Callable 接口的区别就是 Runnable 不会返回结果,Callable 会返回结果。

主线程可以执行 futureTask.get() 方法来阻塞当前线程直到任务执行完成,任务完成后返回任务执行的结果。

futureTask.get(long timeout, TimeUnit unit) 方法则会阻塞当前线程一段时间立即返回,这时候有可能任务没有执行完。

主线程也可以执行 futureTask.cancel(boolean mayInterruptIfRunning) 来取消此任务的执行。

futureTask.isCancelled方法表示任务是否被取消成功,如果在任务正常完成前被取消成功,则返回 true。

futureTask.isDone方法表示任务是否已经完成,若任务完成,则返回true。

【编辑推荐】

  1. Java 8中用法优雅的Stream,性能也"优雅"吗?
  2. Web性能优化:理解及使用JavaScript缓存
  3. Java开发者希望未来使用Python和Go
  4. 将来会是Python、Java、Golang三足鼎立的局面吗?
  5. 几行JavaScript代码构建计算机视觉程序,这里有6个js框架
【责任编辑:武晓燕 TEL:(010)68476606】
点赞 0

(编辑:核心网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

热点阅读