JUC多线程:创建线程的四种方式

JUC多线程:创建线程的四种方式

在 Java 中,实现多线程的主要有以下四种:

(1)继承 Thread 类,重写 run() 方法;

(2)实现 Runnable 接口,实现 run() 方法,并将 Runnable 实现类的实例作为 Thread 构造函数的参数 target;

(3)实现 Callable 接口,实现 call() 方法,然后通过 FutureTask 包装器来创建 Thread 线程;

(4)通过 ThreadPoolExecutor 创建线程池,并从线程池中获取线程用于执行任务;

第(1)(2)种方式无法获取线程的执行结果,因为通过重写的 run()  方法的返回值是void;第(3)种方式可以获取线程的执行结果,因为通过 Callable 接口的 call() 方法的返回值是 Object,可以将返回的结果可以放在 Object 对象中;第(4)种方式对于两种情况都支持,具体取决于任务的类型,有返回值的任务必须实现 Callable 接口,无返回值的任务必须实现 Runnable 接口。

1、继承Thread类的方式:

Thread 实现了 Runnable 接口,代表一个线程的实例。启动线程的唯一方法就是通过 Thread 类的start() 方法。start() 方法是一个native方法,它将启动一个新线程,并执行run()方法。

这种方式实现多线程很简单,直接 extends Thread,并重写 run() 方法,就可以启动新线程执行自己定义的run()方法。例如:

public class MyThread extends Thread {  
  public void run() {  
   System.out.println("MyThread.run()");  
  }  
}  
MyThread myThread1 = new MyThread();  
MyThread myThread2 = new MyThread();  
myThread1.start();  
myThread2.start();

2、通过实现 Runnable 接口:

通过实现 Runnable 接口,实现 run() 方法,将 Runnable  接口的实现类的实例作为 Thread 的带参构造函数中,并通过调用 start() 方法启动线程,如下:

public class ThreadDemo02 {
    public static void main(String[] args){ 
        System.out.println(Thread.currentThread().getName());
        Thread t1 = new Thread(new MyThread());
        t1.start(); 
    }
}
class MyThread implements Runnable{
    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName()+"-->我是通过实现接口的线程实现方式!");
    }   
}

实现 Runnable 接口比继承 Thread 类所具有的优势主要有:

  • ① 可以避免 JAVA 中单继承的限制;
  • ② 线程池只能放入实现 Runable 或 Callable类线程,不能直接放入继承 Thread 的类
  • ③ 代码可以被多个线程共享,代码和数据独立,适合多个相同的程序代码的线程去处理同一个资源的情况

3、实现Callable接口,并通过FutureTask包装器来创建Thread线程:

(1)实现 Callable 接口,并实现 call() 方法; 

(2)创建 Callable 接口的实现类的实例,使用 FutureTask 类包装 Callable 对象,该 FutureTask 对象封装了 Callable 对象的 call() 方法的返回值; 

(3)使用 FutureTask 对象作为 Thread 类的构造函数的 target 参数创建并启动线程;

(4)调用 FutureTask 对象的 get() 来获取子线程执行结束的返回值;

public class ThreadDemo03 {
    public static void main(String[] args) {
        Callable<Object> oneCallable = new Tickets<Object>();
        FutureTask<Object> oneTask = new FutureTask<Object>(oneCallable);
        Thread t = new Thread(oneTask);
        System.out.println(Thread.currentThread().getName());
        t.start();
    }
}
class Tickets<Object> implements Callable<Object>{
    //重写call方法
    @Override
    public Object call() throws Exception {
        System.out.println(Thread.currentThread().getName()+"-->我是通过实现Callable接口通过FutureTask包装器来实现的线程");
        return null;
    }   
}

4、使用 ThreadPoolExecutor 创建线程池:

使用 ThreadPoolExecutor 创建线程池,并从线程池中获取线程用于执行任务。在 JUC 中,Executor 框架已经实现了几种线程池,我们就以 Executor 的 newFixedThreadPool 来作为 Demo 的展示。

import java.util.concurrent.*;  
import java.util.Date;  
import java.util.List;  
import java.util.ArrayList;  
  
/** 
* 有返回值的线程 
*/  
@SuppressWarnings("unchecked")  
public class Test {  
public static void main(String[] args) throws ExecutionException,  
    InterruptedException {  
   System.out.println("----程序开始运行----");  
   Date date1 = new Date();  
  
   int taskSize = 5;  
   // 创建一个线程池  
   ExecutorService pool = Executors.newFixedThreadPool(taskSize);  
   // 创建多个有返回值的任务  
   List<Future> list = new ArrayList<Future>();  
   for (int i = 0; i < taskSize; i++) {  
    Callable c = new MyCallable(i + " ");  
    // 执行任务并获取Future对象  
    Future f = pool.submit(c);  
    // System.out.println(">>>" + f.get().toString());  
    list.add(f);  
   }  
   // 关闭线程池  
   pool.shutdown();  
  
   // 获取所有并发任务的运行结果  
   for (Future f : list) {  
    // 从Future对象上获取任务的返回值,并输出到控制台  
    System.out.println(">>>" + f.get().toString());  
   }  
  
   Date date2 = new Date();  
   System.out.println("----程序结束运行----,程序运行时间【"  
     + (date2.getTime() - date1.getTime()) + "毫秒】");  
}  
}  
  
class MyCallable implements Callable<Object> {  
private String taskNum;  
  
MyCallable(String taskNum) {  
   this.taskNum = taskNum;  
}  
  
public Object call() throws Exception {  
   System.out.println(">>>" + taskNum + "任务启动");  
   Date dateTmp1 = new Date();  
   Thread.sleep(1000);  
   Date dateTmp2 = new Date();  
   long time = dateTmp2.getTime() - dateTmp1.getTime();  
   System.out.println(">>>" + taskNum + "任务终止");  
   return taskNum + "任务返回运行结果,当前任务时间【" + time + "毫秒】";  
}  
} 

ExecutorService、Callable、Future 实际上都是属于 Executor 框架。线程池支持有返回结果和无返回结果的任务,有返回值的任务必须实现Callable接口,无返回值的任务必须实现Runnable接口。对于有结果的任务,执行 Callable 任务后,可以获取一个 Future 的对象,在该对象上调用 get 就可以获取到Callable任务返回的 Object 了,但需要注意的是:get方法是阻塞的,如果线程未返回结果,那么 get() 方法会一直等待,直到有结果返回或者超时。

有关线程池以及 Executor 框架的内容,可以阅读这篇文章:https://blog.csdn.net/a745233700/article/details/109410376

参考文章:https://blog.csdn.net/u011480603/article/details/75332435

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/114622.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • mysql基本命令

    mysql基本命令这里把自己学的mysql数据库的知识总结一下,当是给自己复习一遍,也是方便以后查询安装和配置mysql就不说了,可以借鉴这位博友的安装过程https://www.cnblogs.com/by330

  • SAP BAPI是个啥

    SAP BAPI是个啥BAPI是什么BAPI是啥对象是啥类是啥继承是啥接口是啥package是啥BAPI怎么用BAPI是啥SAPBAPI(业务应用程序编程接口),是针对业务对象模型的标准接口。BAPI是客户代码和第三方应用程序和SAP交互的主要方法。BAPI封装了SAP业务对象模型的内部层,以确保在访问或者更改业务对象时正确执行所有的业务逻辑,验证和授权检查。就是BusinessAPI.接口有个封装的概念,好了,是时候把一波概念写一遍了。要不然我都忘光了。讲接口之前,先看看对象是啥,我依稀记得是Java课上讲的,

  • 什么是变限积分求导公式_积分上限函数求导法则

    什么是变限积分求导公式_积分上限函数求导法则自己理解:当积分上限为被积函数的自变量时,变限积分在某一点的导数等于被积分函数在这一点的值,就是说积分这一点的增量为被积分函数在这一点的值乘以自变量增量区间大小,求导求出来的就是这一点的导数即为被积分

  • 哈希算法

    哈希算法

  • HTML5视频直播技术介绍

    HTML5视频直播技术介绍视频直播如火如荼,为了满足比较火热的移动Web端直播需求,一系列的HTML5直播技术迅速的发展了起来。只要实现了视频直播的各个技术难点,通过HTML5进行视频直播并非难事。常见的可用于HTML5的直播技术共有3种协议:HLS、WebSocket与WebRTC。本文将对基于这3种协议的HTML5直播技术实现做下基础的介绍。一.HLS优点:CDN支持比较好缺点

  • linux重命名文件名_linux 文件重命名

    linux重命名文件名_linux 文件重命名https://blog.csdn.net/weixin_33724570/article/details/91909917https://blog.csdn.net/csdnnews/article/details/87927567https://blog.csdn.net/weixin_34329187/article/details/93004715https://blog…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号