Java多线程阻塞与唤醒代码示例
更新时间：2017年09月28日 11:04:04 作者：Levi_moon
本文主要向大家分享了Java多线程中的阻塞与唤醒的相关内容，通过这篇文章大家可以大致了解到进入线程阻塞状态和可执行状态的方法，需要的朋友可以了解下。
java线程的阻塞及唤醒
1. sleep() 方法：
sleep（…毫秒），指定以毫秒为单位的时间，使线程在该时间内进入线程阻塞状态，期间得不到cpu的时间片，等到时间过去了，线程重新进入可执行状态。（暂停线程，不会释放锁）
//测试sleep（）方法
class Thread7 implements Runnable{
@Override
public void run() {
for(int i=0;i<50;i++){
System.out.println(Thread.currentThread().getName()+"num="+i);
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Thread8 implements Runnable{
@Override
public void run() {
for(int i=0;i<1000;i++){
System.out.println(Thread.currentThread().getName()+"num="+i);
}
}
}
public static void main(String[] args) {
/*
* 测试线程阻塞
*/
//测试sleep（）方法
Thread7 t7=new Thread7();
Thread8 t8=new Thread8();
Thread t81=new Thread(t8, "饺子");
Thread t71=new Thread(t7, "包子");
Thread t72=new Thread(t7, "面包");
t71.start();
t81.start();
t72.start();
}
2.suspend() 和 resume() 方法：。
挂起和唤醒线程，suspend（）使线程进入阻塞状态，只有对应的resume（）被调用的时候，线程才会进入可执行状态。（不建议用，容易发生死锁）
//测试suspend（）和resume（）方法
class Thread9 implements Runnable{
@Override
public void run() {
for(long i=0;i<500000000;i++){
System.out.println(Thread.currentThread().getName()+" num= "+i);
}
}
}
public static void main(String[] args) {
//测试suspend和resume
Thread9 t9=new Thread9();
Thread t91=new Thread(t9,"包子");
t91.start();
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
t91.suspend();
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
t91.resume();
}
（在控制台打印输出的时候，会停顿2秒钟，然后再继续打印。）
3. yield() 方法：
会使的线程放弃当前分得的cpu时间片，但此时线程任然处于可执行状态，随时可以再次分得cpu时间片。yield()方法只能使同优先级的线程有执行的机会。调用 yield() 的效果等价于调度程序认为该线程已执行了足够的时间从而转到另一个线程。（暂停当前正在执行的线程，并执行其他线程，且让出的时间不可知）
//测试yield（）方法
class Thread10 implements Runnable{
@Override
public void run() {
for(int i=0;i<100;i++){
System.out.println(Thread.currentThread().getName()+" num= "+i);
if(i==33){
Thread.yield();
}
}
}
}
public static void main(String[] args) {
//测试yield
Thread10 t10 =new Thread10();
Thread t101=new Thread(t10, "包子");
Thread t102=new Thread(t10, "面包");
t101.start();
t102.start();
}
/*
运行结果为：
……
包子 num= 24
包子 num= 25
包子 num= 26
包子 num= 27
包子 num= 28
包子 num= 29
包子 num= 30
包子 num= 31
包子 num= 32
包子 num= 33
面包 num= 0
面包 num= 1
面包 num= 2
面包 num= 3
……
面包 num= 30
面包 num= 31
面包 num= 32
面包 num= 33
包子 num= 34
包子 num= 35
包子 num= 36
包子 num= 37
包子 num= 38
……
*/
（可以看到，当数字为33时，都发生了交替。）
4.wait() 和 notify() 方法：
两个方法搭配使用，wait（）使线程进入阻塞状态，调用notify（）时，线程进入可执行状态。wait（）内可加或不加参数，加参数时是以毫秒为单位，当到了指定时间或调用notify（）方法时，进入可执行状态。（属于Object类，而不属于Thread类，wait( )会先释放锁住的对象，然后再执行等待的动作。由于wait( )所等待的对象必须先锁住，因此，它只能用在同步化程序段或者同步化方法内，否则，会抛出异常IllegalMonitorStateException.）
//测试wait（）和notify（）方法
//用生产者和消费者模式模拟这一过程
/*消费者 */
class Consumer implements Runnable {
private Vector obj;
public Consumer(Vector v) {
this.obj = v;
}
public void run() {
synchronized (obj) {
while (true) {
try {
if (obj.size() == 0) {
obj.wait();
}
System.out.println("消费者：我要买面包。");
System.out.println("面包数： " + obj.size());
obj.clear();
obj.notify();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
/* 生产者 */
class Producter implements Runnable {
private Vector obj;
public Producter(Vector v) {
this.obj = v;
}
public void run() {
synchronized (obj) {
while (true) {
try {
if (obj.size() != 0) {
obj.wait();
}
obj.add(new String("面包"));
obj.notify();
System.out.println("生产者：面包做好了。");
Thread.sleep(500);
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
public static void main(String[] args) {
//测试wait（）和notify（）
Vector obj = new Vector();
Thread consumer = new Thread(new Consumer(obj));
Thread producter = new Thread(new Producter(obj));
consumer.start();
producter.start();
}
5.join（）方法
也叫线程加入。是当前线程A调用另一个线程B的join（）方法，当前线程转A入阻塞状态，直到线程B运行结束，线程A才由阻塞状态转为可执行状态。
//测试join
class Thread11 implements Runnable{
@Override
public void run() {
System.out.println("Start Progress.");
try {
for(int i=0;i<5;i++){
System.out.println("Thread11线程 : "+i);
Thread.sleep(1000);
}
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("End Progress.");
}
}
public static void main(String[] args) {
//测试join
Thread11 t11=new Thread11();
Thread t111=new Thread(t11);
t111.start();
try {
t111.join();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("hi,I'm Main线程");
}
/*
运行结果为：
Start Progress.
Thread11线程 : 0
Thread11线程 : 1
Thread11线程 : 2
Thread11线程 : 3
Thread11线程 : 4
End Progress.
hi,I'm Main线程
*/
总结
本文关于Java多线程阻塞与唤醒代码示例的介绍就到这里，希望对大家学习Java有所帮助。感兴趣的朋友可以继续参阅：Java多线程ForkJoinPool实例详解 、 Java通过卖票理解多线程 、 Java线程安全基础概念解析等。有什么问题可以随时留言，或者有什么方面想要了解的，您也可以留言，小编会及时给您答复。希望大家对脚本之家多多支持！
相关文章
这篇文章主要介绍了@Scheduled 如何读取动态配置文件的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
详解WebSocket+spring示例demo（已使用sockJs库）
本篇文章主要介绍了WebSocket spring示例demo（已使用sockJs库），小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-01-01
这篇文章主要为大家详细介绍了Java ArrayList实现班级信息管理系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-02-02
这篇文章主要介绍了Java代码生成器的制作流程详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-07-07
这篇文章主要介绍了Java分支结构程序设计例题,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-01-01
lazy-init 是一个非常重要的属性,可以优化应用的启动时间,尤其是在处理大量bean或者复杂依赖关系时,可以显著提高应用的响应速度,本文主要介绍了Spring lazy-init 懒加载的原理小结,感兴趣的可以了解一下2025-04-04
这篇文章主要介绍了java File类的基本使用方法总结，为大家分享了java实现上传代码，感兴趣的小伙伴们可以参考一下2016-04-04
这篇文章主要给大家介绍了关于spring boot创建和数据库关联模块的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-10-10
这篇文章主要介绍了Spring用三级缓存处理循环依赖的方法,在Spring 框架中,依赖注入是其核心特性之一,它允许对象之间的依赖关系在运行时动态注入,然而,当多个Bean之间的依赖关系形成一个闭环时,就会出现循环依赖问题,本文就为解决此问题,需要的朋友可以参考下2025-02-02
这篇文章主要介绍了浅谈Java中对类的主动引用和被动引用，分享了相关代码示例，小编觉得还是挺不错的，具有一定借鉴价值，需要的朋友可以参考下2018-02-02
最新评论