百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 编程网 > 正文

用Java多线程并发编程的时候,你必须得会用Future

yuyutoo 2024-10-12 01:03 6 浏览 0 评论

大家好,今天跟大家聊聊Java里面的多线程并发编程,这个多线程并发编程,想必大家都是懂的,说白了,就是在代码里开启一个新的线程去执行一段代码,然后那段代码什么时候被执行完毕,你可能也不太清楚,但是他总会过一段时间之后执行完毕的。


代码是如何被运行的?

那我们先来看看这个所谓的多线程并发编程到底是怎么个运行原理呢?其实这个问题,我们必须得从main方法开始说起,简单来说,你写一段java代码,其实一般来说启动和执行这些java代码,都必须去运行一个main方法对不对,而且现在比较流行这个spring boot,其实spring boot也是基于main方法来启动的。

那运行代码的时候首先会干什么呢?其实首先他会启动一个JVM进程,接着JVM会去加载你写的类,然后开始运行你的main方法的代码,进而运行你写的所有其他代码,在运行代码的过程中,他需要什么类就把那个类从磁盘上的代码文件里加载到内存里就行了,如下图。

那么这个时候我提一个问题,大家思考一下,那就是JVM进程他是怎么运行main方法的呢?是JVM进程自己直接去执行main方法里面的代码吗?当然不是了,其实所有代码运行都得靠线程,一个进程里是可以开很多线程的,所以JVM进程是会有一个默认的线程,叫做main线程,这个main线程就负责运行我们的main方法的代码了,如下图。


多线程编程是什么?

那么这个时候所谓的多线程编程是什么意思呢?更简单了,如果你要是不开多线程,默认情况下,就是main线程一个线程运行你的main方法以及后续的所有代码。

此时如果你要是想要开启更多的线程同时运行别的代码,可以用new Thread().start()这种代码,直接开启一个线程,那个线程就会同时并发的运行,运行他那部分代码了,注意,多线程是可以并发运行的,也就是说main线程和新开的Thread线程几乎是同时并发运行的,如下图。

那么这个时候问题来了,对于你的main线程来说,开了一个thread线程去执行部分代码,可是问题是,你是希望等到这个thread线程运行结束以后给你一个返回值的,可是你又不知道这个thread线程什么时候运行完毕,你更不知道这个thread线程如何把他的返回值交给你,也就是说,你这个main线程和thread线程之间缺少了一些控制的途径,如下图。

基于FutureTask获取线程返回值

所以在这种情况之下,咱们玩儿多线程并发编程就必须引入Future这个东西了,这个Future呢,其实就代表了你对另外一个线程的控制权,当你开启一个thread线程跑起来以后,你如果可以拿到一个Future,就可以通过这个Future去控制那个线程,比如说中断那个thread线程的运行,比如说通过Future拿到那个线程的返回值,等等,如下图。

所以这个Future在我们用Java写多线程并发编程的时候,是必须要掌握的,因为经常会用到!下面我们来给大家介绍一下这个Future在代码中是怎么来用的!首先,我们来写一段用于给thread子线程运行的任务代码,如下:

public class Task implements Callable<String> {
  
  public String call() throws Exception {
    // 执行一段任务代码,然后得到一个结果,并且返回
    System.out.println("模拟运行任务代码");
    // 默认任务代码运行一共耗时了500ms
    Thread.sleep(500); 
    String result = "模拟返回结果";
    return result;
  }
  
}


接着我们来写一段代码在main方法中用FutureTask开启一个thread线程运行上述代码,并且通过Future去拿到这个thread线程运行完毕代码后返回的结果,代码如下:

public class FutureTaskTest {
  
  public static void main(String[] args) 
  		throws InterruptedException, ExecutionException {
    // 基于我们自己写的任务代码,构建一个FutureTask,这个FutureTask说白了
    // 其实也是一个任务,只不过是用这个JDK提供的FutureTask封装了我们的任务代码
    FutureTask<String> futureTask = 
      new FutureTask<String>(new Task());
    // 构建一个线程池,线程池里会有一个真正运行任务的线程的
    ExecutorService threadPool = Executors.newFixedThreadPool(1);
    // 把FutureTask任务提交到线程池里去,让线程池里的线程运行我们的任务代码
    threadPool.submit(futureTask);
    
    // 这个地方我们可以模拟干了一些别的事情,执行了很多别的代码,过了一段时间
    Thread.sleep(1000);
    
    // 过了一段时间以后,线程池里的线程应该运行完毕我们提交的任务代码了
    // 此时就可以通过FutureTask来获取到那个任务代码运行后的结果
    System.out.println(futureTask.get());
  }
  
}


总结

通过上面的代码,大家就可以看到,当我们用子线程运行执行的一段任务代码时,任务代码运行完毕后是可以返回一个值的,然后我们只要用FutureTask封装这个任务代码,就可以在一段时间过后,通过FutureTask拿到这个任务代码运行完毕后返回的值,这是咱们Java多线程并发编程常用的一种编程技巧,希望大家今天能get到这个Future的妙用。

私信 "面试" 免费领取600+页石杉老师原创精品文章汇总PDF

相关推荐

自卑的人容易患抑郁症吗?(自卑会导致抑郁吗)

Filephoto[Photo/IC]Lowself-esteemmakesusfeelbadaboutourselves.Butdidyouknowthatovert...

中考典型同(近)义词组(同义词考题)

中考典型同(近)义词组...

WPF 消息传递简明教程(wpf messagebox.show)

...

BroadcastReceiver的原理和使用(broadcast-suppression)

一、使用中注意的几点1.动态注册、静态注册的优先级在AndroidManifest.xml中静态注册的receiver比在代码中用registerReceiver动态注册的优先级要低。发送方在send...

Arduino通过串口透传ESP 13板与java程序交互

ESP13---是一个无线板子,配置通过热点通信Arduino通过串口透传ESP13板与java程序交互...

zookeeper的Leader选举源码解析(zookeeper角色选举角色包括)

作者:京东物流梁吉超zookeeper是一个分布式服务框架,主要解决分布式应用中常见的多种数据问题,例如集群管理,状态同步等。为解决这些问题zookeeper需要Leader选举进行保障数据的强一致...

接待外国人英文口语(接待外国友人的英语口语对话)

接待外国人英文口语询问访客身份:  MayIhaveyourname,please?  请问您贵姓?  Whatcompanyareyoufrom?  您是哪个公司的?  Could...

一文深入理解AP架构Nacos注册原理

Nacos简介Nacos是一款阿里巴巴开源用于管理分布式微服务的中间件,能够帮助开发人员快速实现动态服务发现、服务配置、服务元数据及流量管理等。这篇文章主要剖析一下Nacos作为注册中心时其服务注册与...

Android面试宝典之终极大招(android面试及答案)

以下内容来自兆隆IT云学院就业部,根据多年成功就业服务经验,以及职业素养课程部分内容,归纳总结:18.请描述一下Intent和IntentFilter。Android中通过Intent...

除了Crontab,Swoole Timer也可以实现定时任务的

一般的定时器是怎么实现的呢?我总结如下:1.使用Crontab工具,写一个shell脚本,在脚本中调用PHP文件,然后定期执行该脚本;2.ignore_user_abort()和set_time_li...

Spark源码阅读:DataFrame.collect 作业提交流程思维导图

本文分为两个部分:作业提交流程思维导图关键函数列表作业提交流程思维导图...

使用Xamarin和Visual Studio开发Android可穿戴设备应用

搭建开发环境我们需要做的第一件事情是安装必要的工具。因此,你需要首先安装VisualStudio。如果您使用的是VisualStudio2010,2012或2013,那么请确保它是一个专业版本或...

Android开发者必知的5个开源库(android 开发相关源码精编解析)

过去的时间里,Android开发逐步走向成熟,一个个与Android相关的开发工具也层出不穷。不过,在面对各种新鲜事物时,不要忘了那些我们每天使用的大量开源库。在这里,向大家介绍的就是,在这个任劳任怨...

Android事件总线还能怎么玩?(android实现事件处理的步骤)

顾名思义,AndroidEventBus是一个Android平台的事件总线框架,它简化了Activity、Fragment、Service等组件之间的交互,很大程度上降低了它们之间的耦合,使我们的代码...

Android 开发中文引导-应用小部件

应用小部件是可以嵌入其它应用(例如主屏幕)并收到定期更新的微型应用视图。这些视图在用户界面中被叫做小部件,并可以用应用小部件提供者发布。可以容纳其他应用部件的应用组件叫做应用部件的宿主(1)。下面的截...

取消回复欢迎 发表评论: