Student package july.star.thread12;/*** Student* @author MoXingJian* @email 939697374@qq.com* @date 2016年11月30日 下午3:39:45* @version 1.0*/ public class Student {//定義成員變量String name;Integer age;boolean flag;}GetThread package july.star.thread12; /*** GetThread** @author MoXingJian* @email 939697374@qq.com* @date 2016年11月30日 下午3:42:05* @version 1.0*/ public class GetThread implements Runnable {private Student s;public GetThread(Student s) {this.s = s;}@Overridepublic void run() {while (true) {synchronized (s) {//1、沒數據，flag默認為false，進來if (!s.flag) {try {//2 ：等待時釋放鎖s.wait(); //10、回到這里繼續執行} catch (InterruptedException e) {e.printStackTrace();}}//11、輸出結果System.out.println(s.name + ":" + s.age);//標記s.flag = false; //12、標記并喚醒//喚醒s.notify();//13、搶占執行權}}} }SetThread package july.star.thread12; /*** SetThread** @author MoXingJian* @email 939697374@qq.com* @date 2016年11月30日 下午3:40:31* @version 1.0*/ public class SetThread implements Runnable {private Student s;private int count;public SetThread(Student s) {this.s = s;}@Overridepublic void run() {while (true) {synchronized (s) {//3:沒數據，為false，不走wait（）if (s.flag) {try {s.wait(); //9、等待并釋放鎖，轉到GetThread執行} catch (InterruptedException e) {e.printStackTrace();}}if (count % 2 == 0) {s.name = "一菲"; //4、賦值s.age = 21;count++;} else {s.name = "二姐"; s.age = 28;count++;}//修改標記s.flag = true; //6//喚醒s.notify(); //7、喚醒}//8、//搶占CPU執行權，SetThread有或GetThread有權執行//假設SetThread又搶到了 }} }TestThread package july.star.thread12;/*** 簡單生產消費模式* @author MoXingJian* @email 939697374@qq.com* @date 2016年11月30日 下午3:43:19* @version 1.0*/ public class TestThread {public static void main(String[] args) {//創建對象Student s = new Student();//創建線程SetThread st = new SetThread(s);GetThread gt = new GetThread(s);Thread t1 = new Thread(st);Thread t2 = new Thread(gt);//開啟線程t1.start();t2.start();} }

總結

以上是生活随笔為你收集整理的简单生产消费模式的代码流程（Java代码）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。