博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
java多线程异步执行
阅读量:7239 次
发布时间:2019-06-29

本文共 2050 字,大约阅读时间需要 6 分钟。

 

 

import java.util.concurrent.Callable;  import java.util.concurrent.ExecutionException;  import java.util.concurrent.ExecutorService;  import java.util.concurrent.Executors;  import java.util.concurrent.Future;    public class TestMain {        public static void main(String[] args) {            //实现一个Callable接口          Callable
c = new Callable
() { @Override public Netty call() throws Exception { //这里是你的业务逻辑处理 //让当前线程阻塞5秒看下效果 System.out.println("---sleep开始---"); Thread.sleep(5000); System.out.println("---sleep结束---"); return new Netty("张三"); } }; System.out.println("---主线程不被阻塞,继续往下走---"); /*Java通过Executors提供四种线程池,分别为: newCachedThreadPool创建一个可缓存线程池,如果线程池长度超过处理需要,可灵活回收空闲线程,若无可回收,则新建线程。 newFixedThreadPool 创建一个定长线程池,可控制线程最大并发数,超出的线程会在队列中等待。 newScheduledThreadPool 创建一个定长线程池,支持定时及周期性任务执行。 newSingleThreadExecutor 创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行。*/ ExecutorService es = Executors.newCachedThreadPool(); //记得要用submit,执行Callable对象 Future
fn = es.submit(c); //无限循环等待任务处理完毕 如果已经处理完毕 isDone返回true while (!fn.isDone()) { try { //处理完毕后返回的结果 Netty nt = fn.get(); System.out.println("处理完毕后返回的结果:" + nt.name); } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } if (fn.isDone()) { System.out.println("关闭"); es.shutdown(); } System.out.println("全部运行结束"); } static class Netty { private Netty(String name) { this.name = name; } private String name; } }

 

转载地址:http://xhrfm.baihongyu.com/

你可能感兴趣的文章
hibernate中一级缓存和二级缓存
查看>>
【转载】架构师的行为准则(一)
查看>>
RMI,RPC,SOAP对比分析
查看>>
json解析,异步下载(listview仅滑动时加载)Demo总结
查看>>
浅谈12306核心模型设计思路和架构设计
查看>>
基于Solr的空间搜索
查看>>
给vmware的Linux虚拟机添加硬盘
查看>>
XMOVE3.0手持终端——软件介绍(三):在2KB内存的单片机上实现的的俄罗斯方块 (原创)...
查看>>
Kafka实战-Storm Cluster
查看>>
Spring中bean的范围
查看>>
JavaScript实现自适应窗口大小的网页
查看>>
跟我一起数据挖掘(5)——数据类型
查看>>
DIV 拖动效果高级篇
查看>>
SQL SERVER 2012链接到SQL SERVER 2000的问题解决案例
查看>>
Web性能--TCP的构成
查看>>
(十七)java冒泡排序和compareto
查看>>
linux内存查看方式
查看>>
Java魔法堂:String.format详解-
查看>>
线性重复动画
查看>>
炒冷饭系列:设计模式 建造者模式
查看>>