Java多執行緒中執行緒間的通信

一、使用while方式来实现线程之间的通信

package com.ietree.multithread.sync;import java.util.ArrayList;import java.util.List;public class MyList {    
    private volatile static List list = new ArrayList();    public void add() {
        list.add("apple");
    }    public int size() {        return list.size();
    }    public static void main(String[] args) {        final MyList list1 = new MyList();

        Thread t1 = new Thread(new Runnable() {
            @Override            public void run() {                try {                    for (int i = 0; i <p><br></p><p>程序输出：</p><p class="cnblogs_code"><br></p><pre class="brush:php;toolbar:false">当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
Exception in thread "t2" 当前线程收到通知：t2 list size = 5 线程停止..
java.lang.RuntimeException
    at com.ietree.multithread.sync.MyList$2.run(MyList.java:43)
    at java.lang.Thread.run(Unknown Source)
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..

理解：线程Thread2不停地通过while语句检测这个条件(list.size()==5)是否成立 ，从而实现了线程间的通信。但是这种方式会浪费CPU资源。

二、wait notfiy 方法实现多线程中线程之间的通信

使用这种方式实现线程通信需要注意：wait和notify必须配合synchronized关键字使用，wait方法释放锁，notify方法不释放锁。并且在这个例子中必须是Thread2先执行才可以。

    List list =  "apple"    ListAdd2 list2 = 
         Object lock = =  Thread(  ( i = 0; i <p><br></p><p>程序输出：</p><p class="cnblogs_code"><br></p><pre class="brush:php;toolbar:false">当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
已经发出通知..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t2收到通知线程停止..
Exception in thread "t2" java.lang.RuntimeException
    at com.ietree.multithread.sync.ListAdd3$2.run(ListAdd3.java:59)
    at java.lang.Thread.run(Unknown Source)

三、使用CountDownLatch类来实现多线程中线程之间的实时通信

package com.ietree.multithread.sync;import java.util.ArrayList;import java.util.List;import java.util.concurrent.CountDownLatch;public class ListAdd2 {    private volatile static List list = new ArrayList();    public void add() {
        list.add("apple");
    }    public int size() {        return list.size();
    }    public static void main(String[] args) {        final ListAdd2 list2 = new ListAdd2();        final CountDownLatch countDownLatch = new CountDownLatch(1);

        Thread t1 = new Thread(new Runnable() {
            @Override            public void run() {                try {                    for (int i = 0; i <p><br></p><p>程序输出：</p><p class="cnblogs_code"><br></p><pre class="brush:php;toolbar:false">当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
已经发出通知..
Exception in thread "t2" 当前线程：t1添加了一个元素..
当前线程：t2收到通知线程停止..
java.lang.RuntimeException
    at com.ietree.multithread.sync.ListAdd2$2.run(ListAdd2.java:56)
    at java.lang.Thread.run(Unknown Source)
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..
当前线程：t1添加了一个元素..

 

以上是Java多執行緒中執行緒間的通信的詳細內容。更多資訊請關注PHP中文網其他相關文章！