Java教程

Thread线程之间的通讯

本文主要是介绍Thread线程之间的通讯,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

线程通讯的例子

两个线程交替打印1~100

涉及到的三个方法:

wait():一旦执行此方法,当前线程就会进入阻塞状态,并且释放同步监视器。

notify():一旦执行此方法,就会唤醒一个被wait的线程。如果有多个线程被wait,优先唤醒优先级高的线程

notifyAll():一旦执行此方法,就会唤醒所有被wait的线程。

说明:

1、wait(),notify(),notifyAll()必须使用在同步代码块或者同步方法中。

2、wait(),notify(),notifyAll()的调用者必须是同步代码块或者同步方法中的同步监视器。否则会出现IllegalMonitorStateException异常。

3、每个类都拥有wait(),notify(),notifyAll()方法,因为这三个方法在上帝类Object中。

package com.gtguigu.java.Thread;

public class Number implements Runnable{
    public static void main(String[] args) {
        Number number = new Number();
        Thread thread1 = new Thread(number,"线程一");
        Thread thread2 = new Thread(number,"线程二");

        thread1.start();
        thread2.start();
    }
    private int num = 1;
    private Object obj = new Object();
    @Override
    public void run() {
        while (true){
            //同步代码块保证线程安全
            synchronized (this){
            //唤醒一个处于wait阻塞状态的线程;
                notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

 运行结果:

 

 

 如果将同步监视器改为obj对象并且没有更改notif方法和wait方法:

 

synchronized (obj){
            //唤醒一个处于wait阻塞状态的线程;
                notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

 

运行结果:

 

 

 

 正确应用方法:

 

synchronized (obj){
            //唤醒一个处于wait阻塞状态的线程;
                obj.notify();
                if (num<=100){
                    System.out.println(Thread.currentThread().getName()+num);
                    num++;
                }else {
                    break;
                }
                try {
                    //使线程进入阻塞状态
                    obj.wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }

 

notify(),wait(),notifyAll()的调用者应该与同步监视器相同。

 

这篇关于Thread线程之间的通讯的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!