package ThreadTest;
import java.util.ArrayList;
import java.util.List;
public class FirstThread {
static List<Object> goods = new ArrayList<>(); //儲存物品的倉庫，最多儲存1
public static void main(String[] args) throws InterruptedException {
Producer thread1 = new Producer();
Consumer thread2 = new Consumer();
Thread p1 = new Thread(thread1, "生產者1");
Thread p2 = new Thread(thread1, "生產者2");
Thread p3 = new Thread(thread1, "生產者3");
Thread c1 = new Thread(thread2, "消費者1");
Thread c2 = new Thread(thread2, "消費者2");
Thread c3 = new Thread(thread2, "消費者3");
p1.start();
p2.start();
p3.start();
c1.start();
c2.start();
c3.start();
}
static class Producer implements Runnable {
@Override
public void run() {
// TODO Auto-generated method stub
int num = 0;
while(true) {
synchronized (goods) {
if(goods.size()==0) {
goods.add("商品" + ++num);
System.out.println(Thread.currentThread().getName()+"生產了第"+num+"個產品");
}
else if(goods.size()>0)
try {
goods.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
static class Consumer implements Runnable {
@Override
public void run() {
// TODO Auto-generated method stub
int num = 0;
while(true) {
synchronized (goods) {
if(goods.size()>0) {
goods.remove("商品"+ ++num);
System.out.println(Thread.currentThread().getName()+"消費了第"+num+"個產品");
}
else if (goods.size()==0)
goods.notify();;
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
為什么所有的生產者不是共用一個num,輸出時每個生產者都會輸出1，2...。我按照書上的例子可以實作共享，是不是這里是內部類的問題，但是如果不用內部類我又怎么實作生產者和消費者之間的通信呢，
順便再問一個問題，那就是我按照書上的例子敲的，但是每次執行的結果都是幾乎由一個視窗完成全部售票，沒有達到上下兩張票的視窗一定不同，代碼如下：
按理來說sleep(100)會保證不讓同一執行緒連續執行
package ThreadTest;
class SaleThread2 implements Runnable {
int tickets = 10;
Object lock = new Object();
@Override
public void run() {
// TODO Auto-generated method stub
while(true) {
synchronized (lock) {
if(tickets>0) {
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"正在出售第"+tickets-- +"張票");
}
}
}
}
}
public class Example12 {
public static void main(String[] args) {
SaleThread2 st = new SaleThread2();
new Thread(st, "視窗1").start();
new Thread(st, "視窗2").start();
new Thread(st, "視窗3").start();
new Thread(st, "視窗4").start();
}
}
uj5u.com熱心網友回復：
第一段程式，num加入同步。
static class Producer implements Runnable {
volatile int num = 0;
@Override
public void run() {
// TODO Auto-generated method stub
while(true) {
synchronized (goods) {
if(goods.size()==0) {
goods.add("商品" + ++num);
System.out.println(Thread.currentThread().getName()+"生產了第"+num+"個產品");
}
else if(goods.size()>0)
try {
goods.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
static class Consumer implements Runnable {
volatile int num = 0;
@Override
public void run() {
// TODO Auto-generated method stub
while(true) {
synchronized (goods) {
if(goods.size()>0) {
goods.remove("商品"+ ++num);
System.out.println(Thread.currentThread().getName()+"消費了第"+num+"個產品");
}
else if (goods.size()==0)
goods.notify();;
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
第2段程式并不能說明什么問題，數字太小偶然性大，你試著把票數調到100 結果會不一樣。
uj5u.com熱心網友回復：
首先非常感謝你的回答，但是volatile修飾num會報錯，volatile只能修飾final型別。
第二段程式每個執行緒執行時會sleep（100），所以應該不存在什么偶然性，應該必然不會讓同一執行緒連續執行
uj5u.com熱心網友回復：
volatile只能修飾final,誰教給你的? 第二段你加了鎖,在鎖里sleep又不會釋放鎖,書上是這么寫的?uj5u.com熱心網友回復：
沒有，我沒學過volatile，我只是按照他說的添加volatile后編譯器報錯，說應該修飾final
uj5u.com熱心網友回復：
第二段懂了，非常感謝
uj5u.com熱心網友回復：
你沒看我添加在哪里么？不然我貼程式干么？
uj5u.com熱心網友回復：
volatile和final類似，只能申明一次，所以不能在run程式塊內申明uj5u.com熱心網友回復：
懂了，謝謝老哥
uj5u.com熱心網友回復：
我發現問題就是出在你把int num=0 寫在run代碼塊內了，我也不知道那本書上教你這么寫的。要知道start其實就是執行run代碼塊的，你把num變為了run代碼塊的區域變數，造成同步不起效了，這里num直接變為全域變數即可。
uj5u.com熱心網友回復：
嗯，是我抄錯了
uj5u.com熱心網友回復：
首先，樓主的這個代碼，使用的是多執行緒技術，不是多行程技術，所以，不能稱之為行程通信。其次，多執行緒技術中，多執行緒可以通過共享變數的方式來互動資料，一般情況下，我們把資料一致性問題稱為執行緒安全，至少我是這樣理解的。
再次，樓主的 Java 基礎還是有些薄弱，建議先鞏固一下 Java 基礎（比如，語法相關的內容）在來撰寫多執行緒方法的程式吧。
變數的可見域，這個詞，樓主有聽說過嗎？ 函式內宣告的變數，可見域只能在函式內部，函式結束后（正常回傳或拋出例外）區域變數會被回收。這就是函式的封裝性，函式內部的變數，只能在函式內部訪問。上面第二點中說過，多執行緒技術可以通過共享變數的方式來進行資料的互訪，那么，要想 num 被多個執行緒訪問（讀寫操作），那就不要在 run 函式里面宣告這個變數。
最后，既然使用了 wait-notify 完成資料同步了，就沒有必要使用Thead.sleep()了吧，我是真沒看懂。sleep 的作用只是讓執行緒讓出CPU的時間片，和執行緒恢復后的執行順序毫無關系，而且，為了提高執行效率，我們的代碼中是非常機會有sleep呼叫的。
還有，while(true) 中 true 條件的死回圈，也是編程中非常忌諱的存在，我們寫程式，尤其是多執行緒技術的程式，都要講究優雅退出的，你整了一個 true 條件的死回圈，怎么結束程式，只能強制殺死行程了，這種強制殺死行程的方式，我們是非常不推薦使用的，復雜一些的程式會出現很大的問題。
（舉個例子，如果你的程式在結束之前要保存程式執行程序中的一些配置資訊，結果，你強制殺死了行程，配置資訊沒有保存，或者保存了一半，下次啟動的時候，要么配置資訊是上次執行前的鳥樣子，要么就是半個組態檔的資訊，啟動都有可能報錯，從而無法啟動了。）
uj5u.com熱心網友回復：
感謝指點，我會好好學基礎的
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/281861.html
標籤：Java SE