FutureTask的介绍和基本使用
作用:它定义了获取任务的执行结果,取消任务的执行,判断任务是否被取消,判断任务是否执行完毕等功能
为什么使用它?
我们先来举个例子
Thread thread=new Thread(()->{.....},"thread");
这样的代码大家应该很熟悉,创建一个线程实例,里边用的Runnabel接口,这样虽然可以实现多线程,但是我们获取不到最后的执行结果,也不能取消任务的执行,所以就很lou,再看下边的图片
我们发现,Runnable刚好有一个子接口叫RunnableFuture,这个接口下有一个实现类实现了它,我们发现这个实现类是有这些功能的,所以我们是不是可以创建一个这样的实例对象去使用
就出现了下边的使用方式:
FutureTask futureTask=new FutureTask<String>(()->"我是你爸爸");Thread thread=new Thread(futureTask,"thread");thread.start();System.out.println(futureTask.get());System.out.println("我是你叔叔");
注意:FutureTask有两个构造方法,如下图,可以传一个Runnale接口实例,另一个参数就是返回值的类型,也就是FutureTask的泛型类型,也可以传一个callable接口,那FutureTask的泛型类型也就是call方法的返回值类型
创建线程池的几种方式
Executors.newSingleThreadExecutor
创建一个单线程的线程池,只有一条线程,如果线程因为异常而停止,会自动新建一个线程补充。
Executors.newFixedThreadPool
创建一个固定大小的线程池,因为采用无界的阻塞队列,所以实际线程数量永远不会变化,适用于负载较重的场景,对当前线程数量进行限制。(保证线程数可控,不会造成线程过多,导致系统负载更为严重)
Executors.newCachedThreadPool
用来创建一个可以无限扩大的线程池,适用于负载较轻的场景,执行短期异步任务。(可以使得任务快速得到执行,因为任务时间执行短,可以很快结束,也不会造成cpu过度切换)
Executors.newScheduledThreadPool
创建一个没有最大线程数限制的可以定时执行线程池,还有创建一个只有单个线程的可以定时执行线程池(Executors.newSingleThreadScheduledExecutor())
Future利用线程池进行操作
public static void main(String[] args) {
//设置线程个数为三个ExecutorService executorService=Executors.newFixedThreadPool(3);FutureTask<String> futureTask=new FutureTask<String>(()->{System.out.println("正在执行代码线程池任务");},"ddfhfdjfhddj");executorService.submit(futureTask);System.out.println("正在执行主线程任务");
}
Future的弊端:
1.在调用get方法时,如果线程任务还没有执行完毕,会继续等待任务执行完毕,才返回,这样就会造成调用get方法下边的代码无法执行,造成阻塞,当然可以通过get方法的重载去设置最长等待时间,然后这样也只能解决一些简单的问题,所以可以通过以下轮训回调方法去判断,但是会造成cpu消耗严重
public static void main(String[] args) throws ExecutionException, InterruptedException {ExecutorService executorService=Executors.newFixedThreadPool(3);FutureTask<String> futureTask=new FutureTask<String>(()->{System.out.println("正在执行代码线程池任务");},"ddfhfdjfhddj");executorService.submit(futureTask);System.out.println("正在执行主线程任务");while (true){if (futureTask.isDone()){System.out.println("任务执行结果"+futureTask.get());}else {System.out.println("正在处理中别着急");}}
}1
cpu消耗问题解决
持续关注后边completeFeture的文章
FutureTask的介绍和基本使用相关推荐
- 多线程:了解一下ForkJoin、FutureTask、BlockingQueue
先了解一下这三种类 FutureTask 在介绍 Callable 时我们知道它可以有返回值,返回值通过 Future 进行封装.FutureTask 实现了 RunnableFuture 接口,该接 ...
- AQS(CountdownLatch、CyclicBarrier、Semaphore)、FutureTask、BlockingQueue、ForkJoin
1. J.U.C - AQS (AbstractQueuedSynchronizer) java.util.concurrent(J.U.C) 大大提高了并发性能,AQS 被认为是 J.U.C 的核心 ...
- 多线程:并发实现方法之J.U.C
java.util.concurrent(J.U.C)大大提高了并发性能. AQS 被认为是 J.U.C 的核心. 什么是AQS? AQS是AbstractQueuedSynchronizer的简称 ...
- 面试:你说你精通Java并发,给我讲讲Java并发之J.U.C
转载自 面试:你说你精通Java并发,给我讲讲Java并发之J.U.C J.U.C J.U.C即java.util.concurrent包,为我们提供了很多高性能的并发类,可以说是java并发的核心. ...
- 电子拍卖系统开发第二天
一.搭建简单的web服务器 首先简单看一下web工程目录及其包的构建: 导入jar包 业务层接口:BussinessService.java package com.xbmu.service;impo ...
- JavaSE基础学习(四)—Java核心类库(下)
目录 思维导图快速预览全文内容 一.异常机制(重点) 1.基本概念 2.异常分类 3.异常的避免 4.异常的捕获 5.异常的抛出 6.自定义异常 二.File类(重点) 1. 基本概念 2.常用方法 ...
- 92. 你说你精通Java并发,那给我讲讲JUC吧
你说你精通Java并发,那给我讲讲J.U.C吧 J.U.C J.U.C和CAS和Unsafe和AQS J.U.C框架 Atomic Locks Collections Executor Tools J ...
- Java并发知识点快速复习手册(上)
前言 本文快速回顾了常考的的知识点,用作面试复习,事半功倍. 面试知识点复习手册 已发布知识点复习手册 Java基础知识点面试手册 快速梳理23种常用的设计模式 Redis基础知识点面试手册 Java ...
- java多线程之线程创建和状态
一.概述 1.上下文切换 即使是单核处理器也支持多线程执行代码,CPU通过给每个线程分配CPU时间片来实现 这个机制.时间片是CPU分配给各个线程的时间,因为时间片非常短,所以CPU通过不停地切 换线 ...
最新文章
- Python学习之路 (一)开发环境搭建
- java选中一格_java-选中排序(新手)
- 在HTML5中如何利用Canvas处理并存储图片
- php脚本来创建一个表,PHP - SQL脚本创建器
- 添加MD5 密码加密
- 数据挖掘算法 1 ID3(python)
- 视觉SLAM十四讲学习笔记-第六讲-非线性优化的非线性最小二乘问题
- Java21天打卡day19-异常
- hdoj 3376,2686 Matrix Again 【最小费用最大流】
- Oracle中“行转列”的实现方式
- 【CarMaker学习笔记】T型路口多车运行实验
- 数据结构_十字链表(C语言)
- ftp服务器目录创建文件夹,ftp服务器目录创建文件夹
- 深度强化学习之A3C网络—理论及代码(小车上山)
- 高考前最后一天,AI 监考老师已就位
- Javescript REVIEW
- 纯前端集成视频会议和聊天室
- 购物足迹功能php,wordpress实现访客足迹功能
- 基带信号与频带信号的基础认识
- java exls_java excel类