Java多线程基本用法总结

这篇是Java多线程基本用法的一个总结。

本篇文章会从一下几个方面来说明Java多线程的基本用法:

  1. 如何使用多线程
  2. 如何得到多线程的一些信息
  3. 如何停止线程
  4. 如何暂停线程
  5. 线程的一些其他用法

如何使用多线程

启动线程的两种方式

Java 提供了2种方式来使用多线程, 一种是编写一个类来继承Thread,然后覆写run方法,然后调用start方法来启动线程。这时这个类就会以另一个线程的方式来运行run方法里面的代码。另一种是编写一个类来实现Runnable接口,然后实现接口方法run,然后创造一个Thread对象,把实现了Runnable接口的类当做构造参数,传入Thread对象,最后该Thread对象调用start方法。

这里的start方法是一个有启动功能的方法,该方法内部回调run方法。所以,只有调用了start方法才会启动另一个线程,直接调用run方法,还是在同一个线程中执行run,而不是在另一个线程执行run

此外,start方法只是告诉虚拟机,该线程可以启动了,也就说该线程在就绪的状态,但不代表调用start就立即运行了,这要等待JVM来决定什么时候执行这个线程。也就是说,如果有两个线程A,B ,A先调用start,B后调用start,不代表A线程先运行,B线程后运行。这都是由JVM决定了,可以认为是随机启动。

下面我们用实际的代码,来说明两种启动线程的方式:

第一种,继承Thread

public class ExampleThread extends Thread{
  @Override
  public void run() {
    super.run();
    System.out.println("这是一个继承自Thread的ExampleThread");
  }
}

测试的代码可以看test目录下的ExampleThreadTest

另一种,实现了Runnable接口

public class ExampleRunable implements Runnable{
  public void run() {
    System.out.println("这是实现Runnable接口的类");
  }
}

测试的代码可以看test目录下的ExampleRunableTest类。

如何得到多线程的一些信息

我们在启动多线程之后,希望能通过一些API得到启动的线程的一些信息。JDK给我们提供了一个Thread类的方法来得到线程的一些信息。

  • 线程的名字 —— getName()
  • 线程的ID —— getId()
  • 线程是否存活 —— isAlive()

得到线程的名字

这些方法是属于Thread的内部方法,所以我们可以用两种方式调用这些方法,一个是我们的类继承Thread来使用多线程的时候,可以用过this来调用。另一种是通过Thread.currentThread() 来调用这些方法。但是这两个方法在不同的使用场景下是有区别的。

我们先简单来看两个方法的使用。

第一个Thread.currentThread()的使用,代码如下:

public class ExampleCurrentThread extends Thread{
  public ExampleCurrentThread(){
    System.out.println("构造方法的打印:" + Thread.currentThread().getName());
  }
  @Override
  public void run() {
    super.run();
    System.out.println("run方法的打印:" + Thread.currentThread().getName());
  }
}

测试的代码如下:

public class ExampleCurrentThreadTest extends TestCase {
  public void testInit() throws Exception{
    ExampleCurrentThread thread = new ExampleCurrentThread();
  }
  public void testRun() throws Exception {
    ExampleCurrentThread thread = new ExampleCurrentThread();
    thread.start();
    Thread.sleep(1000);
  }
}

结果如下:

构造方法的打印:main
run方法的打印:Thread-0
构造方法的打印:main

为什么我们在ExampleCurrentThread内部用Thread.currentThread()会显示构造方法的打印是main,是因为Thread.currentThread()返回的是代码段正在被那个线程调用的信息。这里面很显然构造方法是被main线程执行的,而run方法是被我们自己启动的线程执行的,因为没有给他起名字,所以默认是Thread-0。

接下来,我们在看一看继承自Thread,用this调用。

public class ComplexCurrentThread extends Thread{
  public ComplexCurrentThread() {
    System.out.println("begin=========");
    System.out.println("Thread.currentThread().getName=" + Thread.currentThread().getName());
    System.out.println("this.getName()=" + this.getName());
    System.out.println("end===========");
  }
  @Override
  public void run() {
    super.run();
    System.out.println("run begin=======");
    System.out.println("Thread.currentThread().getName=" + Thread.currentThread().getName());
    System.out.println("this.getName()=" + this.getName());
    System.out.println("run end==========");
  }
}

测试代码如下:

public class ComplexCurrentThreadTest extends TestCase {
  public void testRun() throws Exception {
    ComplexCurrentThread thread = new ComplexCurrentThread();
    thread.setName("byhieg");
    thread.start();
    Thread.sleep(3000);
  }
}

结果如下:

begin=========
Thread.currentThread().getName=main
this.getName()=Thread-0
end===========
run begin=======
Thread.currentThread().getName=byhieg
this.getName()=byhieg
run end==========

首先在创建对象的时候,构造器还是被main线程所执行,所以Thread.currentThread()得到的就是Main线程的名字,但是this方法指的是调用方法的那个对象,也就是ComplexCurrentThread的线程信息,还没有setName,所以是默认的名字。然后run方法无论是Thread.currentThread()还是this返回的都是设置了byhieg名字的线程信息。

所以Thread.currentThread指的是具体执行这个代码块的线程信息。构造器是main执行的,而run方法则是哪个线程start,哪个线程执行run。这么看来,this能得到的信息是不准确的,因为如果我们在run中执行了this.getName(),但是run方法却是由另一个线程start的,我们是无法通过this.getName得到运行run方法的新城的信息的。而且只有继承了Thread的类才能有getName等方法,这对于Java没有多继承的特性语言来说,是个灾难。所有后面凡是要得到线程的信息,我们都用Thread.currentThread()来调用API。

得到线程的ID

调用getID取得线程的唯一标识。这个和上面的getName用法一致,没什么好说的,可以直接看ExampleIdThread和他的测试类ExampleIdThreadTest。

判断线程是否存活

方法isAlive()的作用是测试线程是否处于活动状态。所谓活动状态,就是线程已经启动但是没有终止。即该线程start之后,被认为是存活的。

我们看一下具体的例子:

public class AliveThread extends Thread{
  @Override
  public void run() {
    super.run();
    System.out.println("run方法中是否存活" + "  " + Thread.currentThread().isAlive());
  }
}

测试方法如下:

public class AliveThreadTest extends TestCase {
  public void testRun() throws Exception {
    AliveThread thread = new AliveThread();
    System.out.println("begin == " + thread.isAlive());
    thread.start();
    Thread.sleep(1000);
    System.out.println("end ==" + thread.isAlive());
    Thread.sleep(3000);
  }
}

结果如下:

begin == false
run方法中是否存活  true
end ==false

我们可以发现在start之前,该线程被认为是没有存活,然后run的时候,是存活的,等run方法执行完,又被认为是不存活的。

如何停止线程

判断线程是否终止

JDK提供了一些方法来判断线程是否终止 —— isInterrupted()和interrupted()

停止线程的方式

这个是得到线程信息中比较重要的一个方法了,因为这个和终止线程的方法相关联。先说一下终止线程的几种方式:

  1. 等待run方法执行完
  2. 线程对象调用stop()
  3. 线程对象调用interrupt(),在该线程的run方法中判断是否终止,抛出一个终止异常终止。
  4. 线程对象调用interrupt(),在该线程的run方法中判断是否终止,以return语句结束。

第一种就不说了,第二种stop()方法已经废弃了,因为可能会产生如下原因:

  1. 强制结束线程,该线程应该做的清理工作,无法完成。
  2. 强制结束线程,该线程已操作的加锁对象强制解锁,造成数据不一致。

具体的例子可以看StopLockThread以及他的测试类StopLockThreadTest

第三种,是目前推荐的终止方法,调用interrupt,然后在run方法中判断是否终止。判断终止的方式有两种,一种是Thread类的静态方法interrupted(),另一种是Thread的成员方法isInterrupted()。这两个方法是有所区别的,第一个方法是会自动重置状态的,如果连续两次调用interrupted(),第一次如果是false,第二次一定是true。而isInterrupted()是不会的。

例子如下:

public class ExampleInterruptThread extends Thread{
  @Override
  public void run() {
    super.run();
    try{
      for(int i = 0 ; i < 50000000 ; i++){
        if (interrupted()){
          System.out.println("已经是停止状态,我要退出了");
          throw new InterruptedException("停止.......");
        }
        System.out.println("i=" + (i + 1));
      }
    }catch (InterruptedException e){
      System.out.println("顺利停止");
    }
  }
}

测试的代码如下:

public class ExampleInterruptThreadTest extends TestCase {
  public void testRun() throws Exception {
    ExampleInterruptThread thread = new ExampleInterruptThread();
    thread.start();
    Thread.sleep(1000);
    thread.interrupt();
  }
}

第四种方法和第三种一样,唯一的区别就是将上面的代码中的抛出异常换成return,个人还是喜欢抛出异常,这里处理的形式就比较多,比如打印信息,处理资源关闭或者捕捉之后再重新向上层抛出。

注意一点,我们上面抛出的异常是InterruptedException,这里简单说一下可能产生这个异常的原因,在原有线程sleep的情况下,调用interrupt终止线程,或者先终止线程,再让线程sleep。

如何暂停线程

在JDK中提供了以下两个方法用来暂停线程和恢复线程。

  • suspend()——暂停线程
  • resume()——恢复线程

这两个方法和stop方法一样是被废弃的方法,其用法和stop一样,暴力的暂停线程和恢复线程。这两个方法之所以是废弃的主要由以下两个原因:

  1. 线程持有锁定的公共资源的情况下,一旦被暂停,则公共资源无法被其他线程所持有。
  2. 线程强制暂停,导致该线程执行的操作没有执行完全,这时访问该线程的数据会出现数据不一致。

线程的一些其他用法

线程的其他的一些基础用法如下:

  1. 线程让步
  2. 设置线程的优先级
  3. 守护线程

线程让步

JDK提供yield()方法来让线程放弃当前的CPU资源,将它让给其他的任务去占用CPU时间,但是这也是随机的事情,有可能刚放弃资源,又马上占用时间片了。

具体的例子可以参考ExampleYieldThread以及他的测试类ExampleYieldThreadTest

设置线程的优先级

我们可以设置线程的优先级来让CPU尽可能的将执行的资源给优先级高的线程。Java设置了1-10这10个优先级,又有三个静态变量来提供三个优先级:

  /**
   * The minimum priority that a thread can have.
   */
  public final static int MIN_PRIORITY = 1;

  /**
   * The default priority that is assigned to a thread.
   */
  public final static int NORM_PRIORITY = 5;

  /**
   * The maximum priority that a thread can have.
   */
  public final static int MAX_PRIORITY = 10;

我们可以通过setPriority来设置线程的优先级,可以直接传入上诉三个静态变量,也可以直接传入1-10的数字。设置后线程就会有不同的优先级。如果我们不设置优先级,会是什么情况?

线程的优先级是有继承的特性,如果我们在A线程中启动了B线程,则AB具有相同的优先级。一般我们在main线程中启动线程,就和main线程有一致的优先级。main线程的优先级默认是5。

下面说一下优先级的一些规则:

  • 优先级高的线程一般会比优先级低的线程获得更多的CPU资源,但是不代表优先级高的任务一定先于优先级低的任务先执行完。因为不同优先级的线程中run方法内容可能不一样。
  • 优先级高的线程一定会比优先级低的线程执行的快。如果两个线程是一样的run方法,但是优先级不一样,确实优先级高的线程先执行完。

线程守护

JDK中提供setDaemon的方法来设置一个线程变成守护线程。守护线程的特点是其他非守护线程执行完,守护线程就自动销毁,典型的例子是GC回收器。

具体可以看ExampleDaemonThread和ExampleDaemonThreadTest。

总结

这篇文章主要总结了Java线程的一些基本的用法,关于线程安全,同步的知识,放到了第二篇。

以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,同时也希望多多支持我们!

(0)

相关推荐

  • 详解Java多线程编程中LockSupport类的线程阻塞用法

    LockSupport是用来创建锁和其他同步类的基本线程阻塞原语. LockSupport中的park() 和 unpark() 的作用分别是阻塞线程和解除阻塞线程,而且park()和unpark()不会遇到"Thread.suspend 和 Thread.resume所可能引发的死锁"问题. 因为park() 和 unpark()有许可的存在:调用 park() 的线程和另一个试图将其 unpark() 的线程之间的竞争将保持活性. 基本用法 LockSupport 很类似于二元信号

  • Java多线程的用法详解

    1.创建线程 在Java中创建线程有两种方法:使用Thread类和使用Runnable接口.在使用Runnable接口时需要建立一个Thread实例.因此,无论是通过Thread类还是Runnable接口建立线程,都必须建立Thread类或它的子类的实例.Thread构造函数: public Thread( );  public Thread(Runnable target);  public Thread(String name);  public Thread(Runnable target

  • Java多线程编程中synchronized关键字的基础用法讲解

    多线程编程中,最关键.最关心的问题应该就是同步问题,这是一个难点,也是核心. 从jdk最早的版本的synchronized.volatile,到jdk 1.5中提供的java.util.concurrent.locks包中的Lock接口(实现有ReadLock,WriteLock,ReentrantLock),多线程的实现也是一步步走向成熟化.   同步,它是通过什么机制来控制的呢?第一反应就是锁,这个在学习操作系统与数据库的时候,应该都已经接触到了.在Java的多线程程序中,当多个程序竞争同一

  • 详解Java多线程编程中互斥锁ReentrantLock类的用法

    0.关于互斥锁 所谓互斥锁, 指的是一次最多只能有一个线程持有的锁. 在jdk1.5之前, 我们通常使用synchronized机制控制多个线程对共享资源的访问. 而现在, Lock提供了比synchronized机制更广泛的锁定操作, Lock和synchronized机制的主要区别: synchronized机制提供了对与每个对象相关的隐式监视器锁的访问, 并强制所有锁获取和释放均要出现在一个块结构中, 当获取了多个锁时, 它们必须以相反的顺序释放. synchronized机制对锁的释放是

  • java的多线程用法编程总结

    一.进程与线程 1.进程是什么? 狭义定义:进程是正在运行的程序的实例(an instance of a computer program that is being executed). 广义定义:进程是一个具有一定独立功能的程序关于某个数据集合的一次运行活动.它是操作系统动态执行的基本单元,在传统的操作系统中,进程既是基本的分配单元,也是基本的执行单元. 2.线程是什么? 线程,有时被称为轻量级进程(Lightweight Process,LWP),是程序执行流的最小单元.一个标准的线程由线

  • Java多线程编程中ThreadLocal类的用法及深入

    ThreadLocal,直译为"线程本地"或"本地线程",如果你真的这么认为,那就错了!其实,它就是一个容器,用于存放线程的局部变量,我认为应该叫做 ThreadLocalVariable(线程局部变量)才对,真不理解为什么当初 Sun 公司的工程师这样命名. 早在 JDK 1.2 的时代,java.lang.ThreadLocal 就诞生了,它是为了解决多线程并发问题而设计的,只不过设计得有些难用,所以至今没有得到广泛使用.其实它还是挺有用的,不相信的话,我们一起

  • Java Thread多线程详解及用法解析

    最全面的java多线程用法解析,如果你对Java的多线程机制并没有深入的研究,那么本文可以帮助你更透彻地理解Java多线程的原理以及使用方法. 1.创建线程 在Java中创建线程有两种方法:使用Thread类和使用Runnable接口.在使用Runnable接口时需要建立一个Thread实例.因此,无论是通过Thread类还是Runnable接口建立线程,都必须建立Thread类或它的子类的实例.Thread构造函数: public Thread( ); public Thread(Runnab

  • Java多线程编程之读写锁ReadWriteLock用法实例

    读写锁:分为读锁和写锁,多个读锁不互斥,读锁与写锁互斥,这是由jvm自己控制的,你只要上好相应的锁即可.如果你的代码只读数据,可以很多人同时读,但不能同时写,那就上读锁:如果你的代码修改数据,只能有一个人在写,且不能同时读取,那就上写锁.总之,读的时候上读锁,写的时候上写锁! 三个线程读数据,三个线程写数据示例: 可以同时读,读的时候不能写,不能同时写,写的时候不能读. 读的时候上读锁,读完解锁:写的时候上写锁,写完解锁. 注意finally解锁. package com.ljq.test.th

  • java多线程中的volatile和synchronized用法分析

    本文实例分析了java多线程中的volatile和synchronized用法.分享给大家供大家参考.具体实现方法如下: 复制代码 代码如下: package com.chzhao; public class Volatiletest extends Thread { private static int count = 0; public void run() {         count++;     } public static void main(String[] args) {  

  • Java多线程编程之Lock用法实例

    锁是控制多个线程对共享资源进行访问的工具.通常,锁提供了对共享资源的独占访问.一次只能有一个线程获得锁,对共享资源的所有访问都需要首先获得锁.不过,某些锁可能允许对共享资源并发访问,如 ReadWriteLock(维护了一对相关的锁,一个用于只读操作,另一个用于写入操作) 的读写锁. 1.Lock提供了无条件的.可轮询的.定时的.可中断的锁获取操作,所有加锁和解锁的方法都是显式的. public interface Lock{ void lock(); //加锁 //优先考虑响应中断,而不是响应

随机推荐