package threads; 
import java.util.List;
import java.util.UUID; 
public class Producer extends Thread{ 
 private List<String> storage;//生產(chǎn)者倉庫
 public Producer(List<String> storage) {
  this.storage = storage;
 }
 public void run(){
  //生產(chǎn)者每隔1s生產(chǎn)1~100消息
  long oldTime = System.currentTimeMillis();
  while(true){
   synchronized(storage){
    if (System.currentTimeMillis() - oldTime >= 1000) {
     oldTime = System.currentTimeMillis();
     int size = (int)(Math.random()*100) + 1;
     for (int i = 0; i < size; i++) {
      String msg = UUID.randomUUID().toString();
      storage.add(msg);
     }
     System.out.println("線程"+this.getName()+"生產(chǎn)消息"+size+"條");
     storage.notify();
    }
   }
  }
 }
}

package threads; 
import java.util.List; 
public class Consumer extends Thread{ 
 private List<String> storage;//倉庫
 public Consumer(List<String> storage) {
  this.storage = storage;
 }
 public void run(){
  while(true){
   synchronized(storage){
    //消費(fèi)者去倉庫拿消息的時(shí)候，如果發(fā)現(xiàn)倉庫數(shù)據(jù)為空，則等待
    if (storage.isEmpty()) {
     try {
      storage.wait();
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
    int size = storage.size();
    for (int i = size - 1; i >= 0; i--) {
     storage.remove(i);
    }
    System.out.println("線程"+this.getName()+"成功消費(fèi)"+size+"條消息");
   }
  }
 }
}

package threads; 
import java.util.ArrayList;
import java.util.List; 

public class Storage { 
 private List<String> storage;//生產(chǎn)者和消費(fèi)者共享的倉庫
 public Storage() {
  storage = new ArrayList<String>();
 }
 public List<String> getStorage() {
  return storage;
 }
 public void setStorage(List<String> storage) {
  this.storage = storage;
 } 
}

package threads; 
public class App { 
 public static void main(String[] args) {
  Storage storage = new Storage();
  Producer producer = new Producer(storage.getStorage());
  Consumer consumer = new Consumer(storage.getStorage());
  producer.start();
  consumer.start();
 }
}

public class ThreadTest {
    static final Object obj = new Object();
    private static boolean flag = false;
    public static void main(String[] args) throws Exception {
        Thread consume = new Thread(new Consume(), "Consume");
        Thread produce = new Thread(new Produce(), "Produce");
        consume.start();
        Thread.sleep(1000);
        produce.start();
        try {
            produce.join();
            consume.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    // 生產(chǎn)者線程
    static class Produce implements Runnable {
        @Override
        public void run() {
            synchronized (obj) {
                System.out.println("進(jìn)入生產(chǎn)者線程");
                System.out.println("生產(chǎn)");
                try {
                    TimeUnit.MILLISECONDS.sleep(2000);  //模擬生產(chǎn)過程
                    flag = true;
                    obj.notify();  //通知消費(fèi)者
                    TimeUnit.MILLISECONDS.sleep(1000);  //模擬其他耗時(shí)操作
                    System.out.println("退出生產(chǎn)者線程");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    //消費(fèi)者線程
    static class Consume implements Runnable {
        @Override
        public void run() {
            synchronized (obj) {
                System.out.println("進(jìn)入消費(fèi)者線程");
                System.out.println("wait flag 1:" + flag);
                while (!flag) {  //判斷條件是否滿足，若不滿足則等待
                    try {
                        System.out.println("還沒生產(chǎn)，進(jìn)入等待");
                        obj.wait();
                        System.out.println("結(jié)束等待");
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("wait flag 2:" + flag);
                System.out.println("消費(fèi)");
                System.out.println("退出消費(fèi)者線程");
            }
        }
    }
}