多线程的四种实现方式

栏目: IT技术 · 发布时间: 4年前

内容简介:JDK5.0之后Java多线程的实现方式变成了四种,下面来简单的列举一下,如果需要更深入的了解,强烈建议阅读一下源码。一、继承Thread类重写run()方法:1. 创建一个继承于Thread类的子类

JDK5.0之后 Java 多线程的实现方式变成了四种,下面来简单的列举一下,如果需要更深入的了解,强烈建议阅读一下源码。

一、继承Thread类重写run()方法:

1. 创建一个继承于Thread类的子类

2. 重写Thread类的run() --> 将此线程执行的操作声明在run()中

3. 创建Thread类的子类的对象

4. 通过此对象调用start()

 1 // 1、 创建一个继承于Thread类的子类
 2 class Test1 extends Thread {
 3 
 4     // 2、 重写Thread类的run()
 5     @Override
 6     public void run() {
 7         //Thread.currentThread().getName():获取当前线程的名字
 8         System.out.println("线程需要执行的代码" + "->"
 9                 + Thread.currentThread().getName());
10     }
11 
12 }
13 
14 public class ThreadTest1 {
15     public static void main(String[] args) {
16         // 3、 创建Thread类的子类的对象
17         Test1 test1 = new Test1();
18         
19         //多线程当然可以创建多个对象来开启多个线程
20         Test1 test2 = new Test1();
21         
22         // 4、通过此对象调用start()方法启动线程
23         //start()方法的作用:1)启动当前线程  2)调用当前线程的run()方法
24         test1.start();
25         test2.start();
26     }
27 }

顺便插一句并不是test1先调用了start()方法就一定先比test2先执行,不清楚的小伙伴建议先了解一下多线程的概念,这里主要是对实现多线程的几种方式简单总结,概念不再赘述。

二、实现Runnable接口:

1. 创建一个实现Runnable接口的类

2. 实现Runnable中的run()方法

3. 创建实现类的对象

4. 将此对象作为参数传递到Thread类的构造器中,创建Thread类的对象

5. 通过Thread类的对象调用start()

 1 //1. 创建一个实现Runnable接口的类
 2 class Test2 implements Runnable {
 3     // 2. 实现Runnable中的run()方法
 4     @Override
 5     public void run() {
 6         System.out.println("线程需要执行的代码" + "->"
 7                 + Thread.currentThread().getName());
 8     }
 9 }
10 
11 public class ThreadTest2 {
12     public static void main(String[] args) {
13         // 3. 创建实现类的对象
14         Test2 test = new Test2();
15         // 4. 将此对象作为参数传递到Thread类的构造器中,创建Thread类的对象
16         Thread t1 = new Thread(test);
17         Thread t2 = new Thread(test);
18         // 5. 通过Thread类的对象调用start()
19         t1.start();
20         t2.start();
21 
22     }
23 }

这种实现的方式没有类的单继承性的局限性更适合处理多个线程有共享数据的情况。

三、实现Callable接口

1.创建Callable的实现类

2.实现call方法,将此线程需要执行的操作声明在call()中

3.创建Callable接口实现类的对象

4.将此Callable接口实现类的对象作为传递到FutureTask构造器中,创建FutureTask的对象

5.将FutureTask的对象作为参数传递到Thread类的构造器中,创建Thread对象,并调用start()

6.获取Callable中call方法的返回值

 1 import java.util.concurrent.Callable;
 2 import java.util.concurrent.ExecutionException;
 3 import java.util.concurrent.FutureTask;
 4 
 5 //1.创建Callable的实现类
 6 class Test3 implements Callable<Object>{
 7   //2.实现call方法,将此线程需要执行的操作声明在call()中
 8   @Override
 9   public Object call() throws Exception {
10       int sum = 0;
11       for (int i = 1; i <= 100; i++) {
12           if(i % 2 == 0){
13               System.out.println(i);
14               sum += i;
15           }
16       }
17       return sum;
18       //如果不需要方法返回值
19       //return null;
20   }
21 }
22 
23 
24 public class ThreadTest3 {
25   public static void main(String[] args) {
26       //3.创建Callable接口实现类的对象
27       Test3 numThread = new Test3();
28       //4.将此Callable接口实现类的对象作为传递到FutureTask构造器中,创建FutureTask的对象
29       FutureTask futureTask = new FutureTask(numThread);
30       //5.将FutureTask的对象作为参数传递到Thread类的构造器中,创建Thread对象,并调用start()
31       new Thread(futureTask).start();//用了匿名内部类
       /*可以和上面一样写成(相当于):
        Thread thread = new Thread(futureTask);
        thread.start();
        */
32 
33       try {
34           //6.获取Callable中call方法的返回值
35           //get()返回值即为FutureTask构造器参数Callable实现类重写的call()的返回值。
36           Object sum = futureTask.get();
37           System.out.println("总和为:" + sum);
38       } catch (InterruptedException e) {
39           e.printStackTrace();
40       } catch (ExecutionException e) {
41           e.printStackTrace();
42       }
43   }
44 
45 }

这种创建线程的方式更加的麻烦,但是人家相比较实现Runnable接口的方式更强大

相比实现Runnable接口的好处;

1. call()可以有返回值

2. call()可以抛出异常,被外面的操作捕获,获取异常的信息

3. Callable支持泛型

四、线程池

1. 提供指定线程数量的线程池

2.执行指定的线程的操作。需要提供实现Runnable接口或Callable接口实现类的对象

3.关闭连接池

 1 import java.util.concurrent.ExecutorService;
 2 import java.util.concurrent.Executors;
 3 
 4 /**
 5  * 这里可以用实现Runnable的方式 也可以用实现Callable的方式
 6  * 
 7  */
 8 class Test4 implements Runnable {
 9     @Override
10     public void run() {
11         System.out.println("代码");
12     }
13 }
14 
15 public class ThreadTest4 {
16     public static void main(String[] args) {
17         // 1. 提供指定线程数量的线程池  这里设置为10
18         ExecutorService service = Executors.newFixedThreadPool(10);
19 
20         // 2.执行指定的线程的操作。需要提供实现Runnable接口或Callable接口实现类的对象
21         service.execute(new Test4());// 适合适用于Runnable
22         // service.submit(Callable callable);//适合使用于Callable
23 
24         // 3.关闭连接池
25         service.shutdown();
26     }
27 
28 }

这种方式的好处:

1.提高响应速度(减少了创建新线程的时间)

2.降低资源消耗(重复利用线程池中线程,不需要每次都创建)

3.便于线程管理

以上简单列举了创建线程的四种方式,有不少东西没有写;尤其是第四种,设置线程池属性等都没有演示。对于还在学习基础的小伙伴来说,前两种需要先重点掌握,后面两种可以先了解一下,等有一些多线程基础之后再进行后续学习。


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

TensorFlow实战

TensorFlow实战

黄文坚、唐源 / 电子工业出版社 / 2017-2-1 / 79

Google近日发布了TensorFlow 1.0候选版,这个稳定版将是深度学习框架发展中的里程碑的一步。自TensorFlow于2015年底正式开源,距今已有一年多,这期间TensorFlow不断给人以惊喜,推出了分布式版本,服务框架TensorFlow Serving,可视化工具TensorFlow,上层封装TF.Learn,其他语言(Go、Java、Rust、Haskell)的绑定、Wind......一起来看看 《TensorFlow实战》 这本书的介绍吧!

CSS 压缩/解压工具
CSS 压缩/解压工具

在线压缩/解压 CSS 代码

RGB转16进制工具
RGB转16进制工具

RGB HEX 互转工具