方式一：

/**
 * 兩個線程要是可見的所以要加上votalile
 */public class Test_01 {
    public static void main(String[] args) {
        final Test_01_Container t = new Test_01_Container();
        new Thread(new Runnable() {
            @Override
            public void run() {
                for(int i = 0; i < 10; i++){
                    System.out.println(
 
"add Object to Container " + i);
                    t.add(new Object());
                    try {
                        TimeUnit.SECONDS.sleep(1);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();
        
        
 
new Thread(new Runnable(){
            @Override
            public void run() {
                while(true){
                    if(t.size() == 5){
                        System.out.println("size = 5");
                        break;
                    }
                }
            }
        }).start();
    }
}

 
class Test_01_Container{
    volatile List<Object> container = new ArrayList<>();
    
    public void add(Object o){
        this.container.add(o);
    }
    
    public int size(){
        return this.container.size();
    }
}

方式二：

/**
 * wait notify
 */
package concurrent.t02;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

public class Test_02 {
    public static void main(String[] args) {
        final Test_02_Container t = new Test_02_Container();
        final Object lock = new Object();
        
        new Thread(new Runnable(){
            @Override
            public void run() {
                synchronized (lock) {
                    if(t.size() != 5){
                        try {
                            lock.wait(); // 線程進入等待隊列。
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    System.out.println("size = 5");
                    lock.notifyAll(); // 喚醒其他等待線程
                }
            }
        }).start();
        
        new Thread(new Runnable() {
            @Override
            public void run() {
                synchronized (lock) {
                    for(int i = 0; i < 10; i++){
                        System.out.println("add Object to Container " + i);
                        t.add(new Object());
                        if(t.size() == 5){
                            lock.notifyAll();
                            try {
                                lock.wait();
                            } catch (InterruptedException e) {
                                e.printStackTrace();
                            }
                        }
                        try {
                            TimeUnit.SECONDS.sleep(1);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }
        }).start();
    }
}

class Test_02_Container{
    List<Object> container = new ArrayList<>();
    
    public void add(Object o){
        this.container.add(o);
    }
    
    public int size(){
        return this.container.size();
    }
}

方式三：

/**
 * CountDownLatch 門閂
 */
package concurrent.t02;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

public class Test_03 {
    public static void main(String[] args) {
        final Test_03_Container t = new Test_03_Container();
        final CountDownLatch latch = new CountDownLatch(1);

        new Thread(new Runnable(){
            @Override
            public void run() {
                if(t.size() != 5){
                    try {
                        latch.await(); // 等待門閂的開放。 不是進入等待隊列
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("size = 5");
            }
        }).start();
        
        new Thread(new Runnable() {
            @Override
            public void run() {
                for(int i = 0; i < 10; i++){
                    System.out.println("add Object to Container " + i);
                    t.add(new Object());
                    if(t.size() == 5){
                        latch.countDown(); // 門閂-1
                    }
                    try {
                        TimeUnit.SECONDS.sleep(1);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();
    }
}

class Test_03_Container{
    List<Object> container = new ArrayList<>();
    
    public void add(Object o){
        this.container.add(o);
    }
    
    public int size(){
        return this.container.size();
    }
}

一個類，有新增元素（add）和獲取元素數量（size）方法。 啟動兩個線程。線程1向容器中新增數據。線程2監聽容器元素數量，當容器元素數量為5時，線程2輸出信息並終止