Java--线程同步
在單線程程序中,每次只做一件事情,后面的事情需要等待前面這件事情完成才可以進(jìn)行
如果是多線程程序,這件事情還沒做完就又做另外一件事情,這就可能發(fā)生兩個(gè)線程搶占資源的問題
例如:a與b兩個(gè)人都要去洗手間,洗手間只有一個(gè)位置,a還沒出來,b就已經(jīng)進(jìn)去了,這就很尷尬。。。
Java提供了線程同步的機(jī)制來防止資源訪問的沖突,實(shí)際上線程安全問題來源于多個(gè)線程同時(shí)對(duì)同一對(duì)象的操作
例如:下面的代碼是火車票的售票功能,當(dāng)票數(shù)小于等于0時(shí)停止售票
package java18;
public class ThreadSafe implements Runnable{
?? ?int num = 10;
?? ?@Override
?? ?public void run() {
?? ??? ?while(true)
?? ??? ?{
?? ??? ??? ?if(num>0)
?? ??? ??? ?{
?? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ?Thread.sleep(100);
?? ??? ??? ??? ?}catch(Exception e) {
?? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ?}
?? ??? ??? ??? ?System.out.println("tickets"+num--);
?? ??? ??? ?}
?? ??? ?}
?? ?}
?? ?public static void main(String[] args)
?? ?{
?? ??? ?ThreadSafe t = new ThreadSafe();
?? ??? ?Thread tA = new Thread(t);
?? ??? ?Thread tB = new Thread(t);
?? ??? ?Thread tC = new Thread(t);
?? ??? ?Thread tD = new Thread(t);
?? ??? ?tA.start();
?? ??? ?tB.start();
?? ??? ?tC.start();
?? ??? ?tD.start();
?? ?}
}
這個(gè)代碼運(yùn)行后輸出的票數(shù)num會(huì)出現(xiàn)負(fù)數(shù)(-1,-2),這是為什么呢?
原因在此:,例如:現(xiàn)在num為1,當(dāng)tA執(zhí)行時(shí),觀察到num>0,售出票,執(zhí)行sleep,還沒有來得及對(duì)num進(jìn)行自減操作,tB發(fā)現(xiàn)num現(xiàn)在是1,于是也執(zhí)行售出票的操作,這就剩一張票,卻賣出了兩次,出現(xiàn)了問題。
那么有什么辦法解決這個(gè)問題呢?Java中提供了同步機(jī)制
例如:a與b現(xiàn)在又去這個(gè)洗手間,a進(jìn)去以后把門給鎖了,b想進(jìn)去也打不開門,只能等a出來再進(jìn)去
package java18;
public class ThreadSafe implements Runnable{
?? ?int num = 10;
?? ?@Override
?? ?public void run() {
?? ??? ?while(true)
?? ??? ?{
?? ??? ??? ?synchronized(""){if(num>0)??
?? ??? ??? ?{
?? ??? ??? ??? ?try {
?? ??? ??? ??? ??? ?Thread.sleep(100);
?? ??? ??? ??? ?}catch(Exception e) {
?? ??? ??? ??? ??? ?e.printStackTrace();
?? ??? ??? ??? ?}
?? ??? ??? ??? ?System.out.println("tickets"+num--);
?? ??? ??? ?}
?? ??? ?}}
?? ?}
?? ?public static void main(String[] args)
?? ?{
?? ??? ?ThreadSafe t = new ThreadSafe();
?? ??? ?Thread tA = new Thread(t);
?? ??? ?Thread tB = new Thread(t);
?? ??? ?Thread tC = new Thread(t);
?? ??? ?Thread tD = new Thread(t);
?? ??? ?tA.start();
?? ??? ?tB.start();
?? ??? ?tC.start();
?? ??? ?tD.start();
?? ?}
}
?
總結(jié)
以上是生活随笔為你收集整理的Java--线程同步的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Leetcode--695. 岛屿的最大
- 下一篇: java美元兑换,(Java实现) 美元