java并发基础篇(五): 创建线程的四种方式

概述

线程的创建一共有四种方式:

  • 继承于Thread类,重写run()方法;
  • 实现Runable接口,实现里面的run()方法;
  • 使用 FutureTask 实现有返回结果的线程
  • 使用ExecutorServiceExecutors 线程池。

在详细了解这四种方法之前,先来理解一下为什么线程要这样创建:形象点来说,Thread是一个工人,run()方法里面的便是他的任务栏,这个任务栏默认是空的。当你想要这个线程做点什么时,你可以重写Thread里面的run方法,重写这个工人的任务栏;也可以通过runable、callable接口,从外部赋予这个工人任务。还可以将任务交给一堆工人,谁有空就谁就承担这个任务(线程池)。

一、四种方式的详细介绍

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

1Thread thread = new MyThread();
2    //线程启动
3thread.start();

MyThread 类

1//继承Thread
2class MyThread extends Thread{
3    //重写run方法
4    @Override
5    public void run() {
6        //任务内容....
7        System.out.println("当前线程是:"+Thread.currentThread().getName());
8    }
9}

运行结果: 当前线程是:Thread-0

如果线程类使用的很少,那么可以使用匿名内部类,请看下面的例子:

1Thread thread = new Thread(){
2        @Override
3        public void run() {
4            //任务内容....
5            System.out.println("当前线程是:"+Thread.currentThread().getName());
6        }
7    };

2、实现Runable接口,实现里面的run()方法:

第一种方法- -继承Thread类的方法,一般情况下是不建议用的,因为java是单继承结构,一旦继承了Thread类,就无法继承其他类了。所以建议使用 实现Runable接口 的方法;

1Thread thread = new Thread(new MyTask());
2    //线程启动
3thread.start();

MyTask 类:

1//实现Runnable接口
2class MyTask implements Runnable{
3    //重写run方法
4    public void run() {
5        //任务内容....
6        System.out.println("当前线程是:"+Thread.currentThread().getName());
7    }
8}

同样,如果这个任务类(MyTask )用的很少,也可以使用匿名内部类:

1Thread thread = new Thread(new Runnable() {
2        @Override
3        public void run() {
4            //任务内容....
5            System.out.println("当前线程是:"+Thread.currentThread().getName());
6        }
7    });

3、使用 FutureTask 实现有返回结果的线程

FutureTask 是一个可取消的异步计算任务,是一个独立的类,实现了 Future、Runnable接口。FutureTask 的出现是为了弥补 Thread 的不足而设计的,可以让程序员跟踪、获取任务的执行情况、计算结果

因为 FutureTask实现了 Runnable,所以 FutureTask 可以作为参数来创建一个新的线程来执行,也可以提交给 Executor 执行。FutureTask 一旦计算完成,就不能再重新开始或取消计算。

FutureTask的构造方法

可以接受 Runnable,Callable 的子类实例。

1//创建一个 FutureTask,一旦运行就执行给定的 Callable。
2public FutureTask(Callable<V> callable);
3//创建一个 FutureTask,一旦运行就执行给定的 Runnable,并安排成功完成时 get 返回给定的结果 。
4public FutureTask(Runnable runnable, V result)
5

FutureTask 的简单例子

 1public class Test {
 2  public static void main(String[] args) throws InterruptedException, ExecutionException {
 3    FutureTask<Double> task = new FutureTask(new MyCallable());
 4    //创建一个线程,异步计算结果
 5    Thread thread = new Thread(task);
 6    thread.start();
 7    //主线程继续工作
 8    Thread.sleep(1000);
 9    System.out.println("主线程等待计算结果...");
10    //当需要用到异步计算的结果时,阻塞获取这个结果
11    Double d = task.get();
12    System.out.println("计算结果是:"+d);
13    //用同一个 FutureTask 再起一个线程
14    Thread thread2 = new Thread(task);
15    thread2.start();
16}
17}
18class MyCallable implements Callable<Double>{
19    @Override
20    public Double call() {
21         double d = 0;
22         try {
23             System.out.println("异步计算开始.......");
24              d = Math.random()*10;
25             d += 1000;
26            Thread.sleep(2000);
27             System.out.println("异步计算结束.......");
28        } catch (InterruptedException e) {
29            e.printStackTrace();
30        }
31        return d;
32    }
33}

运行结果: 异步计算开始……. 主线程等待计算结果… 异步计算结束……. 计算结果是:1002.7806590582911

四、使用线程池ExecutorSerice、Executors

前面三种方法,都是显式地创建一个线程,可以直接控制线程,如线程的优先级、线程是否是守护线程,线程何时启动等等。而第四种方法,则是创建一个线程池,池中可以有1个或多个线程,这些线程都是线程池去维护,控制程序员不需要关心这些细节,只需要将任务提交给线程池去处理便可,非常方便。

创建线程池的前提最好是你的任务量大,因为创建线程池的开销比创建一个线程大得多。

创建线程池的方式

ExecutorService是一个比较重要的接口,实现这个接口的子类有两个 ThreadPoolExecutor (普通线程池)、ScheduleThreadPoolExecutor (定时任务的线程池)。你可以通过这两个类来创建一个线程池,但要传入各种参数,不太方便。

为了方便用户,JDK中提供了工具类Executors,提供了几个创建常用的线程池的工厂方法。由于篇幅原因,不细说,可参考我的并发系列文章。

Executors 创建单线程的线程池

 1public class MyTest {
 2    public static void main(String[] args) {
 3         //创建一个只有一个线程的线程池
 4         ExecutorService executorService = Executors.newSingleThreadExecutor();
 5         //创建任务,并提交任务到线程池中
 6         executorService.execute(new MyRunable("任务1"));
 7         executorService.execute(new MyRunable("任务2"));
 8         executorService.execute(new MyRunable("任务3"));
 9    }
10}
11class MyRunable implements Runnable{
12    private String taskName;
13    public MyRunable(String taskName) {
14        this.taskName = taskName;
15    }
16    @Override
17    public void run() {
18        System.out.println("线程池完成任务:"+taskName);
19    }
20}

二、关于run()方法的思考

看看下面这种情况:线程类Thread 接收了外部任务,同时又用匿名内部类的方式重写了内部的run()方法,这样岂不是有两个任务,那么究竟会执行那个任务呢?还是两个任务一起执行呢?

1Thread thread = new Thread(new MyTask()){
2        @Override
3        public void run() {//重写Thread类的run方法
4            System.out.println("Thread 类的run方法");
5        }
6    };
7    //线程启动
8    thread.start();
1//实现Runnable接口
2class MyTask implements Runnable{
3    //重写run方法
4    @Override
5    public void run() {
6        //任务内容....
7        System.out.println("这是Runnable的run方法");
8    }
9}

运行结果: Thread 类的run方法

通过上面的结果,可以看出:线程最后执行的是Thread类内部的run()方法,这是为什么呢?我们先来分析一下JDK的Thread源码:

1private Runnable target;
2public void run() {  
3    if (target != null) {  
4        target.run();  
5    }  
6}  

一切都清晰明了了,Thread类的run方法在没有重写的情况下,是判断一下是否有Runnable 对象传进来,如果有,那么就调用Runnable 对象里的run方法;否则,就什么都不干,线程结束。所以,针对上面的例子,一旦你继承重写了Thread类的run()方法,而你又想可以接收Runable类的对象,那么就要加上super.run(),执行没有重写时的run方法,改造的例子如下:

1Thread thread = new Thread(new MyTask()){
2        @Override
3        public void run() {//重写Thread类的run方法
4           //调用父类Thread的run方法,即没有重写时的run方法
5            super.run();
6            System.out.println("Thread 类的run方法");
7        }
8    };

运行结果: 这是Runnable的run方法 Thread 类的run方法

出处:http://www.cnblogs.com/jinggod/p/8485106.html


原文发布于微信公众号 - 好好学java(SIHAIloveJAVA)

原文发表时间:2018-07-06

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏PHP实战技术

PHP面试常考易错题之变量作用域解析

PHP面试中变量作用域是面试中常常出现的问题,也是必考的问题,下面就给大姐讲解一下在面试中注意的点:

13540
来自专栏desperate633

深入理解SortSet类型的使用及应用Redis 有序集合(sorted set)SortSet的应用场景SortSet的常用命令

Redis 有序集合和集合一样也是string类型元素的集合,且不允许重复的成员。

35420
来自专栏mukekeheart的iOS之旅

Java基础——多线程

  Java中多线程的应用是非常多的,我们在Java中又该如何去创建线程呢? http://www.jianshu.com/p/40d4c7aebd66 一、...

26550
来自专栏从流域到海域

《笨办法学Python》 第33课手记

《笨办法学Python》 第33课手记 本节课讲while循环,作者强调while循环的缺点在于循环可能永远进行下去,所以作者推荐使用for循环,在确认循环会结...

19560
来自专栏猿天地

面试题-实现多线程的方式

每个线程都有自己的票总量,处理的都是自己的票,就是说每个窗口各自卖各自的票,这就是继承实现线程的特点,一个线程处理一件事情

10630
来自专栏君赏技术博客

颤抖吧!都在我的魔法下颤抖吧!--------我是 iOS 黑魔法师!

对于子类 B重写父类 A方法 method2在 iOS6.0之后才可以用是错误的,因为父类方法是可以在 iOS5.0就可以用的。

8610
来自专栏F_Alex

数据结构与算法(三)-线性表之静态链表

前言:前面介绍的线性表的顺序存储结构和链式存储结构中,都有对对象地引用或指向,也就是编程语言中有引用或者指针,那么在没有引用或指针的语言中,该怎么实现这个的数据...

19120
来自专栏小樱的经验随笔

getline函数(精华版)

在我的印象中,getline函数经常出现在自己的视野里,模糊地记得它经常用来读取字符串 。但是又对它的参数不是很了解,今天又用到了getline函数,现在来细细...

38940
来自专栏小樱的经验随笔

记一次拿webshell踩过的坑(如何用PHP编写一个不包含数字和字母的后门)

这一串代码描述是这样子,我们要绕过A-Za-z0-9这些常规数字、字母字符串的传参,将非字母、数字的字符经过各种变换,最后能构造出 a-z 中任意一个字符,并且...

19820
来自专栏yang0range

Java的面试基础题(二)

1)特点:存储对象;长度可变;存储对象的类型可不同 2)Collection (1)List:有序的;元素可重复,有索引 (add(index, elem...

19120

扫码关注云+社区

领取腾讯云代金券