05 线程通信

Posted alichengxuyuan

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了05 线程通信相关的知识,希望对你有一定的参考价值。

# 问题
java中的线程通信机制有哪些
# 答案
线程同步也是线程通信的一种,例如这个线程修改了某个数据,另一个线程读取了修改后的数据,这本质上就是通信。Object类提供的wait(), notify(),notifyAll()是我们通常讲得线程通信,它们被引入的意义在于由轮询侦听变为事件触发。例如以下的代码:
```
import java.util.Arrays;
import java.util.Comparator;

public class Test {
    public synchronized void test1()
    {
        System.out.println(Thread.currentThread().getName()+" test1()");
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        Test test = new Test();
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                test.test1();
            }
        });

        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                test.test1();
            }
        });
        //当thread线程正在执行test1方法的时候,thread1线程就得等着;
        //等到thread执行完毕,thread1才能执行,但是thread1怎么才能知道thread执行完毕呢,就得不断去轮询。
        //轮询的效率是比较低的,那有没有更高效率的办法呢,wait以及notify就是解决这个问题的。
        thread.start();
        thread1.start();
    }
}
```
当thread线程正在执行test1方法的时候,thread1线程就得等着;等到thread执行完毕,thread1才能执行,但是thread1怎么才能知道thread执行完毕呢,就得不断去轮询。轮询的效率是比较低的,那有没有更高效率的办法呢,wait以及notify就是解决这个问题的。
例如:thread1发现thread正在执行,就wait等待,等到thread执行完毕,就去notify唤醒thread1。如此一来,thread1就不用轮询查看thread是否执行完毕,效率得以提高。那么上面的代码就可以变为:
```
public class Test1 {


    public void test1()
    {
        while(true) {
            synchronized (this) {
                System.out.println(Thread.currentThread().getName() + " test1()");
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                notify();
                try {
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }

    public static void main(String[] args) {
        Test1 test = new Test1();
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                test.test1();
            }
        });

        Thread thread1 = new Thread(new Runnable() {
            @Override
            public void run() {
                test.test1();
            }
        });
        //thread执行完毕,唤醒thread1,阻塞自己;
        //thread1执行完毕,唤醒thread,阻塞自己。
        //如此,周而复始,不断循环。
        thread.start();
        thread1.start();
    }
}
```
wait(), notify(), notifyAll()之所以必须写在synchronized代码块当中,是因为他们的作用就是对“多个线程对同一个资源进行操作会产生轮询”进行优化;而它们为什么写在Object类中,是因为synchronized的对象锁可以是任意对象。

以上是关于05 线程通信的主要内容,如果未能解决你的问题,请参考以下文章

并发技术05传统线程同步通信技术

Java进程间通信和线程间通信?

用于线程间通信的 Windows 套接字

阶段1 语言基础+高级_1-3-Java语言高级_05-异常与多线程_第4节 等待唤醒机制_5_线程间通信

Delphi - OTL - 线程池和工作线程之间的通信

在子进程运行和通信时终止子进程,这些子进程通过队列干净地通信