• linkedu视频
  • 平面设计
  • 电脑入门
  • 操作系统
  • 办公应用
  • 电脑硬件
  • 动画设计
  • 3D设计
  • 网页设计
  • CAD设计
  • 影音处理
  • 数据库
  • 程序设计
  • 认证考试
  • 信息管理
  • 信息安全
菜单
linkedu.com
  • 网页制作
  • 数据库
  • 程序设计
  • 操作系统
  • CMS教程
  • 游戏攻略
  • 脚本语言
  • 平面设计
  • 软件教程
  • 网络安全
  • 电脑知识
  • 服务器
  • 视频教程
  • JavaScript
  • ASP.NET
  • PHP
  • 正则表达式
  • AJAX
  • JSP
  • ASP
  • Flex
  • XML
  • 编程技巧
  • Android
  • swift
  • C#教程
  • vb
  • vb.net
  • C语言
  • Java
  • Delphi
  • 易语言
  • vc/mfc
  • 嵌入式开发
  • 游戏开发
  • ios
  • 编程问答
  • 汇编语言
  • 微信小程序
  • 数据结构
  • OpenGL
  • 架构设计
  • qt
  • 微信公众号
您的位置:首页 > 程序设计 >Java > Java中实现多线程关键词整理(总结)

Java中实现多线程关键词整理(总结)

作者:aheizi 字体:[增加 减小] 来源:互联网 时间:2017-05-28

aheizi 通过本文主要向大家介绍了java 多线程关键字,java线程关键字,java线程同步关键字,java多线程编程,java多线程实现聊天等相关知识,希望对您有所帮助,也希望大家支持linkedu.com www.linkedu.com

Java中的Runable,Callable,Future,FutureTask,ExecutorService,Excetor,Excutors,ThreadPoolExcetor在这里对这些关键词,以及它们的用法做一个总结。

首先将它们分个类:

Runable,Callable
Future,FutureTask
ExecutorService,Excetor,Excutors,ThreadPoolExcetor

1. 关于Ranable和Callable

首先Java中创建线程的方法有三种:

  1. 继承Thread类,覆盖run方法
  2. 实现Runable接口,实现run方法
  3. 实现Callable接口,实现run方法

三种实现的优缺点:

继承Thread,单继承的缘故,不能再继承其他类,获取当前线程this

实现Runable接口,没有返回值,获取当前线程Thread.currentThread()

实现Callable接口,可通过Future.get()获取返回值,获取当前线程 Thread.currentThread()

继承Thread,两个步骤:

class DemoThread extends Thread {
  @Override
  public void run() {
    super.run();
    // Perform time-consuming operation...
  }
}
DemoThread t = new DemoThread();
t.start();
</div>
  • 继承Thread类,覆盖run()方法。
  • 创建线程对象并用start()方法启动线程。

实现Runable,一般使用如下:

new Thread(new Runnable() {
  @Override
  public void run() {
    // do something
  }
}).start();
</div>

为了简单。

以上两种方式获取线程执行的结果相当麻烦,不能直接获取。JDK1.5增加了 Callable, Callable 的 call() 方法可以返回值和抛出异常。Callable 可以返回装载有计算结果的 Future 对象。
Callable的源码:

public interface Callable<V> {
  V call() throws Exception;
}

</div>

Callable的基本使用方法:

FutureTask<Integer> futureTask = new FutureTask<Integer>(new Callable<Integer>() {
  @Override
  public Integer call() throws Exception {
    // do something
    return null;
  }
});
Thread thread = new Thread(futureTask);
thread.start();
Integer result = futureTask.get();
</div>

运行 Callable 任务可以拿到一个 Future 对象,通过Future的get()方法拿到线程执行的返回值。那么...Future,

FutureTask区别是什么,怎么使用?

->next()

2. 关于Future和FutureTask

为了获取线程的执行结果,引入了Future的FutureTask,那么他们是什么关系,如何使用?

Future类位于java.util.concurrent包下,它是一个接口:

public interface Future<V> {
  boolean cancel(boolean mayInterruptIfRunning);
  boolean isCancelled();
  boolean isDone();
  V get() throws InterruptedException, ExecutionException;
  V get(long timeout, TimeUnit unit)
    throws InterruptedException, ExecutionException, TimeoutException;
}
</div>

Future 定义了5个方法:

1)boolean cancel(boolean mayInterruptIfRunning):试图取消对此任务的执行。如果任务已完成、或已取消,或者由于某些其他原因而无法取消,则此尝试将失败。当调用 cancel() 时,如果调用成功,而此任务尚未启动,则此任务将永不运行。如果任务已经启动,则 mayInterruptIfRunning 参数确定是否应该以试图停止任务的方式来中断执行此任务的线程。此方法返回后,对 isDone() 的后续调用将始终返回 true。如果此方法返回 true,则对 isCancelled() 的后续调用将始终返回 true。

2)boolean isCancelled():如果在任务正常完成前将其取消,则返回 true。

3)boolean isDone():如果任务已完成,则返回 true。 可能由于正常终止、异常或取消而完成,在所有这些情况中,此方法都将返回 true。

4)V get()throws InterruptedException,ExecutionException:如有必要,等待计算完成,然后获取其结果。

5)V get(long timeout,TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException: 如有必要,最多等待为使计算完成所给定的时间之后,获取其结果(如果结果可用)。

总的来说Future提供了三种功能:

判断任务是否完成;

能够中断任务;

能够获取任务执行结果。

重点:

RunnableFuture继承了Runnable接口和Future接口,而FutureTask实现了RunnableFuture接口。

FutureTask的实现:

public class FutureTask<V> implements RunnableFuture<V>

</div>

RunnableFuture接口的实现:

public interface RunnableFuture<V> extends Runnable, Future<V> {
  void run();
}

</div>

FutureTask是Future接口的一个唯一实现类。

除了可以用Thread包装FutureTask外,还有另一种使用方法:

ExecutorService executor = Executors.newCachedThreadPool();
FutureTask<Integer> futureTask = new FutureTask<Integer>(new Callable<Integer>() {
  @Override
  public Integer call() throws Exception {
    // do something
    return null;
  }
});
executor.submit(futureTask);
Integer result = futureTask.get();
</div>

这里用到了Executor 框架。

->next();

3. 关于ExecutorService,Excetor,Excutors,ThreadPoolExcetor

Executor框架在Java 5中被引入,Executor 框架是一个根据一组执行策略调用、调度、执行和控制的异步任务的框架。
在说Executor 框架之前我们需要引入一个新的概念——线程池(ThreadPoolExecutor):

public ThreadPoolExecutor(intcorePoolSize,
    int maximumPoolSize,
    long keepAliveTime,
    TimeUnit unit,
    BlockingQueue<Runnable> workQueue,
    ThreadFactory threadFactory,
    RejectedExecutionHandler handler)

</div>

ThreadPoolExecutor是Executors类的底层实现。

在JDK帮助文档中,有如此一段话:

“强烈建议程序员使用较为方便的 Executors 工厂方法 Executors.newCachedThreadPool()(无界线程池,可以进行自动线程回收)、Executors.newFixedThreadPool(int)(固定大小线程池)和 Executors.newSingleThreadExecutor()(单个后台线程),它们均为大多数使用场景预定义了设置。”

那么ExecutorService,Excetor,Excutors都是什么?
Excetor是一个抽象层面的核心接口:

public interface Executor {
  void execute(Runnable command);
}
</div>

ExecutorService 接口 对 Executor 接口进行了扩展,提供了返回 Future 对象,终止,关闭线程池等方法。

public interface ExecutorService extends Executor {
  void shutdown();
  <T> Future<T> submit(Callable<T> task);
  <T> Future<T> submit(Runnable task, T result);
  <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException;
}
</div>

Executors 是一个工具类,类似于 Collections。提供工厂方法来创建不同类型的线程池,比如 FixedThreadPool 或 CachedThreadPool。

public class Executors {
  public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>());
    }
    
   public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>());
    }
}
</div>

以上是对Java多线程关键词的整理,不至于一团乱麻。

以上所述是小编给大家介绍的Java中实现多线程关键词整理,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!

</div>
分享到:QQ空间新浪微博腾讯微博微信百度贴吧QQ好友复制网址打印

您可能想查找下面的文章:

  • Java中实现多线程关键词整理(总结)
  • Java中实现多线程关键词整理(总结)

相关文章

  • 2017-05-28Java代理模式详细解析
  • 2017-05-28java中Callback简单使用总结
  • 2017-05-28Java多线程并发编程 并发三大要素
  • 2017-05-28详解使用Spring Boot开发Web项目
  • 2017-05-28SpringBoot整合JPA的实例代码
  • 2017-05-28老生常谈Java异常处理和设计(推荐)
  • 2017-05-28java仿Servlet生成验证码实例详解
  • 2017-05-28详解spring封装hbase的代码实现
  • 2017-05-28java 中HttpClient传输xml字符串实例详解
  • 2017-05-28MyBatis的嵌套查询解析

文章分类

  • JavaScript
  • ASP.NET
  • PHP
  • 正则表达式
  • AJAX
  • JSP
  • ASP
  • Flex
  • XML
  • 编程技巧
  • Android
  • swift
  • C#教程
  • vb
  • vb.net
  • C语言
  • Java
  • Delphi
  • 易语言
  • vc/mfc
  • 嵌入式开发
  • 游戏开发
  • ios
  • 编程问答
  • 汇编语言
  • 微信小程序
  • 数据结构
  • OpenGL
  • 架构设计
  • qt
  • 微信公众号

最近更新的内容

    • SpringMVC之简单的增删改查示例(SSM整合)
    • 利用Java异常机制实现模拟借书系统
    • Java 队列 Queue 用法实例详解
    • Java List简介_动力节点Java学院整理
    • java 中Comparable与Comparator详解与比较
    • Java HTTP协议收发MQ 消息代码实例详解
    • Java 简化正则表达式的使用
    • Java经典排序算法之插入排序
    • java实现ftp文件上传下载功能
    • JAVA 中解密RSA算法JS加密实例详解

关于我们 - 联系我们 - 免责声明 - 网站地图

©2020-2025 All Rights Reserved. linkedu.com 版权所有