Java线程(四):线程中断、线程让步、线程睡眠、线程合并

最近在Review线程专栏,修改了诸多之前描述不够严谨的地方,凡是带有Review标记的文章都是修改过了。本篇文章是插进来的,因为原来没有写,现在来看传统线程描述的不太完整,所以就补上了。理解了线程同步和线程通信之后,再来看本文的知识点就会简单的多了,本文是做为传统线程知识点的一个补充。有人会问:JDK5之后有了更完善的处理多线程问题的类(并发包),我们还需要去了解传统线程吗?答:需要。在实际开发中,无外乎两种情况,一个是开发新内容,另一个是维护原有程序。开发新内容可以使用新的技术手段,但是我们不能保证原有程序是用什么实现的,所以我们需要了解原有的。另外一点,了解传统线程的工作原理,使我们在使用并发包时更加得心应手。

线程中断

       线程中断涉及到三个方法,如下:

void

interrupt()           中断线程。

static boolean

interrupted()           测试当前线程是否已经中断。

boolean

isInterrupted()           测试线程是否已经中断。

       interrupt()方法用于中断线程,通常的理解来看,只要某个线程启动后,调用了该方法,则该线程不能继续执行了,来看个小例子:

public class InterruptTest {
	public static void main(String[] args) throws InterruptedException {
		MyThread t = new MyThread("MyThread");
		t.start();
		Thread.sleep(100);// 睡眠100毫秒
		t.interrupt();// 中断t线程
	}
}
class MyThread extends Thread {
	int i = 0;
	public MyThread(String name) {
		super(name);
	}
	public void run() {
		while(true) {// 死循环,等待被中断
			System.out.println(getName() + getId() + "执行了" + ++i + "次");
		}
	}
}

       运行后,我们发现,线程t一直在执行,没有被中断,原来interrupt()是骗人的,汗!其实interrupt()方法并不是中断线程的执行,而是为调用该方法的线程对象打上一个标记,设置其中断状态为true,通过isInterrupted()方法可以得到这个线程状态,我们将上面的程序做一个小改动:

public class InterruptTest {
	public static void main(String[] args) throws InterruptedException {
		MyThread t = new MyThread("MyThread");
		t.start();
		Thread.sleep(100);// 睡眠100毫秒
		t.interrupt();// 中断t线程
	}
}
class MyThread extends Thread {
	int i = 0;
	public MyThread(String name) {
		super(name);
	}
	public void run() {
		while(!isInterrupted()) {// 当前线程没有被中断,则执行
			System.out.println(getName() + getId() + "执行了" + ++i + "次");
		}
	}
}

       这样的话,线程被顺利的中断执行了。很多人实现一个线程类时,都会再加一个flag标记,以便控制线程停止执行,其实完全没必要,通过线程自身的中断状态,就可以完美实现该功能。如果线程在调用 Object 类的 wait()、wait(long) 或 wait(long, int) 方法,或者该类的 join()、join(long)、join(long, int)、sleep(long) 或 sleep(long, int) 方法过程中受阻,则其中断状态将被清除,它还将收到一个 InterruptedException。 我们可以捕获该异常,并且做一些处理。另外,Thread.interrupted()方法是一个静态方法,它是判断当前线程的中断状态,需要注意的是,线程的中断状态会由该方法清除。换句话说,如果连续两次调用该方法,则第二次调用将返回 false(在第一次调用已清除了其中断状态之后,且第二次调用检验完中断状态前,当前线程再次中断的情况除外)。

线程让步

static void

yield()           暂停当前正在执行的线程对象,并执行其他线程

       线程让步用于正在执行的线程,在某些情况下让出CPU资源,让给其它线程执行,来看一个小例子:

public class YieldTest {
	public static void main(String[] args) throws InterruptedException {
		// 创建线程对象
		YieldThread t1 = new YieldThread("t1");
		YieldThread t2 = new YieldThread("t2");
		// 启动线程
		t1.start();
		t2.start();
		// 主线程休眠100毫秒
		Thread.sleep(100);
		// 终止线程
		t1.interrupt();
		t2.interrupt();
	}
}
class YieldThread extends Thread {
	int i = 0;
	public YieldThread(String name) {
		super(name);
	}
	public void run() {
		while(!isInterrupted()) {
			System.out.println(getName() + "执行了" + ++i + "次");
			if(i % 10 == 0) {// 当i能对10整除时,则让步
				Thread.yield();
			}
		}
	}
}

       输出结果略,从输出结果可以看到,当某个线程(t1或者t2)执行到10次、20次、30次等时,就会马上切换到另一个线程执行,接下来再交替执行,如此往复。注意,如果存在synchronized线程同步的话,线程让步不会释放锁(监视器对象)

线程睡眠

static void

sleep(long millis)           在指定的毫秒数内让当前正在执行的线程休眠(暂停执行)。

static void

sleep(long millis, int nanos)           在指定的毫秒数加指定的纳秒数内让当前正在执行的线程休眠(暂停执行)。

线程睡眠的过程中,如果是在synchronized线程同步内,是持有锁(监视器对象)的,也就是说,线程是关门睡觉的,别的线程进不来,来看一个小例子:

public class SleepTest {
	public static void main(String[] args) {
		// 创建共享对象
		Service service = new Service();
		// 创建线程
		SleepThread t1 = new SleepThread("t1", service);
		SleepThread t2 = new SleepThread("t2", service);
		// 启动线程
		t1.start();
		t2.start();
	}
	
}
class SleepThread extends Thread {
	private Service service;
	public SleepThread(String name, Service service) {
		super(name);
		this.service = service;
	}
	public void run() {
		service.calc();
	}
}
class Service {
	public synchronized void calc() {
		System.out.println(Thread.currentThread().getName() + "准备计算");
		System.out.println(Thread.currentThread().getName() + "感觉累了,开始睡觉");
		try {
			Thread.sleep(10000);// 睡10秒
		} catch (InterruptedException e) {
			return;
		}
		System.out.println(Thread.currentThread().getName() + "睡醒了,开始计算");
		System.out.println(Thread.currentThread().getName() + "计算完成");
	}
}

       输出结果:

t1准备计算
t1感觉累了,开始睡觉
t1睡醒了,开始计算
t1计算完成
t2准备计算
t2感觉累了,开始睡觉
t2睡醒了,开始计算
t2计算完成

线程合并

void

join()           等待该线程终止。

void

join(long millis)           等待该线程终止的时间最长为 millis 毫秒。

void

join(long millis, int nanos)           等待该线程终止的时间最长为 millis 毫秒 + nanos 纳秒。

       线程合并是优先执行调用该方法的线程,再执行当前线程,来看一个小例子:

public class JoinTest {
	public static void main(String[] args) throws InterruptedException {
		JoinThread t1 = new JoinThread("t1");
		JoinThread t2 = new JoinThread("t2");
		t1.start();
		t2.start();
		t1.join();
		t2.join();
		System.out.println("主线程开始执行!");
	}
}
class JoinThread extends Thread {
	public JoinThread(String name) {
		super(name);
	}
	public void run() {
		for(int i = 1; i <= 10; i++)
			System.out.println(getName() + getId() + "执行了" + i + "次");
	}
}

       t1和t2都执行完才继续主线程的执行,所谓合并,就是等待其它线程执行完,再执行当前线程,执行起来的效果就好像把其它线程合并到当前线程执行一样。

线程优先级

java.lang.Thread

public static final int

MAX_PRIORITY

10

public static final int

MIN_PRIORITY

1

public static final int

NORM_PRIORITY

5

wait()和sleep()区别

       区别太大了,但是在Java线程面试题中是很常见的问题,相信你阅读过本专栏后,能够轻松的解答,这里不再赘述。

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

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Java编程

Java多线程技能

我有一个微信公众号,经常会分享一些Java技术相关的干货。如果你喜欢我的分享,可以用微信搜索“Java团长”或者“javatuanzhang”关注。

3821
来自专栏微信公众号:Java团长

Java多线程技能

773
来自专栏令仔很忙

新手学JAVA(十一)-多线程----线程的生命周期

当一个线程被创建并启动之后,并不是一开始就处于执行状态,已不是一直处于运行状态。线程也是有生命周期的,包括:创建(New)、就绪(Runnable)、阻塞(B...

711
来自专栏Java面试通关手册

Java多线程学习(四)等待/通知(wait/notify)机制

我自己总结的Java学习的系统知识点以及面试问题,目前已经开源,会一直完善下去,欢迎建议和指导欢迎Star: https://github.com/Snailc...

1203
来自专栏LanceToBigData

Java多线程(一)

多线程在面试中经常会被问到,所以也是非常重要的知识。 看到一篇写的很不错的博客:http://www.cnblogs.com/GarfieldEr007/p/5...

1798
来自专栏linux驱动个人学习

main函数是主线程吗

1、线程的概念: 线程是程序最基本的运行单位,而进程不能运行,所以能运行的,是进程中的线程。 2、线程是如何创建起来的: 进程仅仅是一个容器,包含了线程运行中所...

3004
来自专栏你不就像风一样

Java多线程核心技术(六)线程组与线程异常

调用与线程有关的方法是造成线程状态改变的主要原因,其关系如图所示:(图片来源于网络)

582
来自专栏好好学java的技术栈

深入线程Thread类的start()方法和run()方法

java的线程是通过java.lang.Thread类来实现的。VM启动时会有一个由主方法所定义的线程。可以通过创建Thread的实例来创建新的线程。每个线程都...

530
来自专栏青枫的专栏

JDK5中Lock锁的使用

(1)JDK5中Lock锁的使用   虽然我们可以理解同步代码块和同步方法的锁对象问题,但是我们并没有直接看到在哪里加上了锁,在哪里释放了锁,为了更清晰的...

271
来自专栏Java Edge

JUC源码分析之CyclicBarrier简介关键方法与参数源码解析CountDownLatch和CyclicBarrier的区别与联系应用场景小结

3298

扫码关注云+社区