浅谈Java线程间通信方式

这篇文章主要为大家详细介绍了Java线程间的通信方式，以代码结合文字的方式来讨论线程间的通信，感兴趣的朋友可以参考一下

1.volatile和synchronized关键字

volatile关键字保证了共享变量的可见性，任何线程需要读取时都要到内存中读取（确保获得最新值）。synchronized关键字确保只能同时有一个线程访问方法或者变量，保证了线程访问的可见性和排他性。

synchronized底层是基于监视器（Monitor）的获取，每个对象都有自己的监视器，线程必须获得监视器才能继续执行内容。

浅谈Java线程间通信方式

2.等待/通知机制

等待/通知机制，是指一个线程A调用了对象O的wait()方法进入等待状态，而另一个线程B 调用了对象O的notify()或者notifyAll()方法，线程A收到通知后从对象O的wait()方法返回，进而执行后续操作。上述两个线程通过对象O来完成交互，而对象上的wait()和notify/notifyAll()的关系就如同开关信号一样，用来完成等待方和通知方之间的交互工作（注意此机制要和锁一起使用，调用notify的线程执行完后释放了锁新唤醒线程才能运行）。

浅谈Java线程间通信方式

3.管道输入/输出流

管道输入/输出流和普通的文件输入/输出流或者网络输入/输出流不同之处在于，它主要用于线程之间的数据传输，而传输的媒介为内存。

管道输入/输出流主要包括了如下4种具体实现：PipedOutputStream、PipedInputStream、 PipedReader和PipedWriter，前两种面向字节，而后两种面向字符。

				?

									public class Piped {

									    public static void main(String[] args) throws Exception {

									        PipedWriter out = new PipedWriter();

									        PipedReader in = new PipedReader(); // 将输出流和输入流进行连接，否则在使用时会抛出IOException

									        out.connect(in);

									        Thread printThread = new Thread(new Print(in), "PrintThread");

									        printThread.start();

									        int receive = 0;

									        try {

									            while ((receive = System.in.read()) != -1) {

									                out.write(receive);

									            }

									        } finally {

									            out.close();

									        }

									    }

									    static class Print implements Runnable {

									        private PipedReader in;

									        public Print(PipedReader in) {

									            this.in = in;

									        }

									        public void run() {

									            int receive = 0;

									            try {

									                while ((receive = in.read()) != -1) {

									                    System.out.print((char) receive);

									                }

									            } catch (IOException ex) {

									            }

									        }

									    }

									}

4.join()方法

如果一个线程A执行了thread.join()语句，其含义是：当前线程A等待thread线程终止之后才从thread.join()返回。线程Thread除了提供join()方法之外，还提供了join(long millis)和join(long millis,int nanos)两个具备超时特性的方法。这两个超时方法表示，如果线程thread在给定的超时时间里没有终止，那么将会从该超时方法中返回。

每个线程终止的前提是前驱线程的终止，每个线程等待前驱线程终止后，才从join()方法返回，这里涉及了等待/通知机制（等待前驱线程结束，接收前驱线程结束通知）。