Java多线程

#Java多线程| 来源: 网络整理| 查看: 265

场景

本篇博客主要目的是总结，为了在工作中需要用到的时候，随时可以快速找到，毕竟人的记忆力是有限的。下面我们就快速总结一下 Java 实现多线程异步执行耗时代码的四种方式，以便在工作中需要用到的时候，随时可以快速找到。

参考相关链接: https://www.cnblogs.com/studyjobs/p/15763937.html https://blog.csdn.net/qq_42764468/article/details/122988589

文章目录实现方式一继承 Thread 类实现方式二、实现 Runnable 接口实现方式三、实现 Callable 接口（有返回值）实现方式四、使用线程池

实现方式一继承 Thread 类

继续 Thread 的子类，需要用到的方法介绍：

方法名说明void run()在线程开启后，此方法将被调用执行，不能直接调用该方法实现多线程void start()使此方法开启一个新线程并开始执行，Java虚拟机会自动调用 run方法

实现步骤：

定义一个类MyThread继承Thread类在MyThread类中重写run()方法创建MyThread类的对象启动线程

代码实现：

public class MyThread extends Thread { @Override public void run() { for(int i=0; i public static void main(String[] args) { MyThread my1 = new MyThread(); MyThread my2 = new MyThread(); //这里直接调用 run 方法，并不会开启新线程执行 //my1.run(); //my2.run(); //必须调用 start 方法，才能开启新线程并自动调用 run 方法 my1.start(); my2.start(); } } 实现方式二、实现 Runnable 接口

需要用到的 Thread 构造方法介绍：

方法名说明Thread(Runnable target)传入实现了 Runnable 接口的类，构造一个 Thread 对象Thread(Runnable target, String name)传入实现了 Runnable 接口的类，构造一个名称为 name 的 Thread 对象

实现步骤：

定义一个类 MyRunnable 实现 Runnable 接口在 MyRunnable 类中实现 run() 方法创建 MyRunnable 类的对象创建 Thread 类的对象，把 MyRunnable 对象作为构造方法的参数启动线程

代码实现：

public class MyRunnable implements Runnable { @Override public void run() { for(int i=0; i public static void main(String[] args) { MyRunnable my = new MyRunnable(); //Thread t1 = new Thread(my); //Thread t2 = new Thread(my); Thread t1 = new Thread(my,"线程一"); Thread t2 = new Thread(my,"线程二"); //启动线程 t1.start(); t2.start(); } } 实现方式三、实现 Callable 接口（有返回值）

需要用到的 Thread 构造方法介绍：

方法名说明V call()这是 Callable 接口中要实现的方法，相当于 Runnable 接口中的 run 方法FutureTask(Callable callable)使用 Callable 接口实现类实例创建一个 FutureTask，它运行时会调配用 Callable 接口中的 call 方法V get()FutureTask 实例的 get 方法，可以阻塞代码继续往下执行，直到获取到异步线程中的返回结果为止

实现步骤：

定义一个类 MyCallable 实现 Callable 接口在 MyCallable 类中重实现 call() 方法创建 MyCallable 类的对象创建 FutureTask 对象，把 MyCallable 对象作为构造方法的参数创建 Thread 类的对象，把 FutureTask 对象作为构造方法的参数启动线程如果想获取返回值的话，可以调用get方法，就可以获取线程结束之后的结果

代码实现：

//因为这里想返回 String 值，所以实现 String 类型的 Callable 接口 public class MyCallable implements Callable { @Override public String call() throws Exception { for (int i = 0; i public static void main(String[] args) throws ExecutionException, InterruptedException { MyCallable mc = new MyCallable(); //因为 MyCallable 实现了 String 类型的 Callable 接口 //所以返回值也是 String 类型，所以创建的是 String 类型的 FutureTask 对象 FutureTask ft = new FutureTask(mc); //传入 FutureTask 实例，创建线程对象 Thread t1 = new Thread(ft); //不能在这个地方使用 FutureTask 的 get 方法获取异步线程的返回值，否则程序将卡死在这里。 //因为 t1 线程还没有执行，所以无法获取到返回值，所以如果执行 get 方法，程序将卡死在这里。 //String s = ft.get(); //开启新线程，异步执行 MyCallable 实例中的 call 方法逻辑 t1.start(); //这里编写一些实现其它业务逻辑代码进行执行 //可以做一些其它比较耗时的任务 //...... //获取异步线程的返回值 String s = ft.get(); System.out.println(s); } } 实现方式四、使用线程池

以下使用不同的线程类型时要注意

Runnbale类型：为 threadpool.executeCallable类型：为threadpool.submit