用互斥與同步的知識寫售票系統
我在run()方法里運用了互斥與同步的知識，但無法實現三個線程售出五張票的功能，因為在售出一張票之后（完成操作后）做不到既能使線程不結束又能釋放鎖資源。
為了便于理解，我來解釋一下：
要求（實現的功能）是這樣的：三個窗口（線程）公平競爭五張票，哪些窗口可以售票，一個窗口可以售多少張票由系統決定，這意味著每次運行的結果都不一樣。“希望線程不結束”是因為該線程售出一張票后仍然有機會售票，“又能釋放鎖資源”是因為其他線程也可以售票。
以下是我的代碼，望大神賜教，不勝感激：
public class SoldTicketThread implements Runnable {
private int ticket=5;
Object lock=new Object();
public void run() {
synchronized(lock){
while(ticket<=0){
try {
lock.wait();
} catch (InterruptedException e) {
System.out.println("已售空，請等待");
}
}
/*while(ticket>0){
System.out.println(Thread.currentThread().getName()+
"賣出了一張票，剩余"+(--ticket)+"張票");
}*/
System.out.println(Thread.currentThread().getName()+
"賣出了一張票，剩余"+(--ticket)+"張票");
//Thread.yield();
lock.notifyAll();
}
}
}
在另一個文件（類）測試：
public class MainMenu {
public static void main(String[] args) {
SoldTicketThread window=new SoldTicketThread();
Thread wd1=new Thread(window,"窗口二");
Thread wd2=new Thread(window,"窗口一");
Thread wd3=new Thread(window,"窗口三");
wd1.start();
wd2.start();
wd3.start();
try {
wd1.join();
wd2.join();
wd3.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
2020-04-08
16年的帖子 19年的回答。。。
2019-10-10
class?MyThread2?implements?Runnable{ ????private?int?ticketsCont?=?100;//一共5張火車票 ????private?final?Object?lockObj?=?new?Object(); ????@Override ????public?void?run()?{ ????????while?(true){ ????????????synchronized?(lockObj){ ????????????????while?(ticketsCont<=0){ ??????????????????System.out.println(Thread.currentThread().getName()+"沒票了"); ????????????????????try?{ ????????????????????????lockObj.wait(); ????????????????????}?catch?(InterruptedException?e)?{ ????????????????????????e.printStackTrace(); ????????????????????} ????????????????} ????????????????ticketsCont--;????//如果還有票，就賣掉一張 ????????????????System.out.println(Thread.currentThread().getName()+"賣了一張票，剩余票數為"+ticketsCont); ????????????????try?{ ????????????????????Thread.sleep(500); ????????????????}?catch?(InterruptedException?e)?{ ????????????????????e.printStackTrace(); ????????????????} ????????????????lockObj.notifyAll(); ????????????} ????????} ????} } public?class?TicketsRunnable?{ ????public?static?void?main(String[]?args)?{ ????????MyThread2?mt?=new?MyThread2(); ????????//創建三個線程，模擬三個窗口賣票 ????????Thread?th1?=?new?Thread(mt,"窗口1"); ????????Thread?th2?=?new?Thread(mt,"窗口2"); ????????Thread?th3?=?new?Thread(mt,"窗口3"); ????????//啟動這三個線程 ????????th1.start(); ????????th2.start(); ????????th3.start(); ????} }運行結果 我的可以實現 你可以參考一下? 有問題可以探討哈
2016-09-18
你每個線程只執行了一次呀思密達。你的關注點只落在鎖上了，忽略了每個線程要去循環執行呀。
public void run() {
while(true){
synchronized(lock){
while(ticket<=0){
System.out.println(Thread.currentThread().getName()+
"while剩余"+ticket+"張票");
try {
lock.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+
"賣出了一張票，剩余"+(--ticket)+"張票");
lock.notifyAll();
}
}
}