1.1 多線程賣票案例
需求:用三個(gè)線程模擬三個(gè)售票窗口,共同賣100張火車票,每個(gè)線程打印出賣第幾張票
1.1.1 案例代碼三:

package com.itheima_03; public class TicketThread implements Runnable { int tickets = 100;//火車票數(shù)量 @Override public void run() { //出售火車票 while(true) { //當(dāng)火車票小于0張，則停止售票 if(tickets > 0) { /** t1,t2,t3* 假設(shè)只剩一張票* t1過(guò)來(lái)了，他一看有票，他就進(jìn)來(lái)了，但是他突然肚子不舒服，然后他就去上衛(wèi)生間了* t2也過(guò)來(lái)了，他一看也有票，他也進(jìn)來(lái)了，但是他的肚子也不舒服，他也去上衛(wèi)生間了** t1上完了衛(wèi)生間回來(lái)了，開始售票* tickets = 0;* t2也上完衛(wèi)生間回來(lái)了，他也進(jìn)行售票* tickets = -1;***/ try { Thread.sleep(100); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + ":" +tickets--); } } }}

1.2 多線程安全問(wèn)題解決
1.2.1 使用同步代碼塊解決

格式:[/align] synchronized(鎖對(duì)象){//需要同步的代碼 }

1.2.1.1 案例代碼四:

package com.itheima_04; /** 問(wèn)題出現(xiàn)的原因：* 要有多個(gè)線程* 要有被多個(gè)線程所共享的數(shù)據(jù)* 多個(gè)線程并發(fā)的訪問(wèn)共享的數(shù)據(jù)** 在火車上上廁所* 張三來(lái)了，一看門是綠的，他就進(jìn)去了，把門鎖上了，門就變紅了* 李四來(lái)了，一看門市紅色的，他就只能憋著* 張三用完了廁所，把鎖打開了，門就變成了綠色* 李四一看門變綠了，他就進(jìn)去了，把門鎖上，門就變紅了* 王五來(lái)了，一看們是紅色的，他也只能憋著* 李四用完測(cè)試了，把鎖打開了，肚子又不舒服了，扭頭回去了，又把門鎖上了，** synchronized:同步（鎖），可以修飾代碼塊和方法，被修飾的代碼塊和方法一旦被某個(gè)線程訪問(wèn)，則直接鎖住，其他的線程將無(wú)法訪問(wèn)** 同步代碼塊：* synchronized(鎖對(duì)象){** }** 注意：鎖對(duì)象需要被所有的線程所共享*** 同步：安全性高，效率低* 非同步：效率高，但是安全性低**/ public class TicketThread implements Runnable { int tickets = 100;//火車票數(shù)量 Object obj = new Object(); @Override public void run() { //出售火車票 while(true) { synchronized (obj) {if(tickets > 0) { try { Thread.sleep(100); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + ":" +tickets--); } } } }} package com.itheima_04;public class TicktetTest { public static void main(String[] args) { //創(chuàng)建線程對(duì)象 TicketThread tt = new TicketThread(); Thread t = new Thread(tt); t.setName("窗口1"); Thread t2 = new Thread(tt); t2.setName("窗口2"); Thread t3 = new Thread(tt); t3.setName("窗口3"); //啟動(dòng)線程對(duì)象 t.start(); t2.start(); t3.start(); } }

1.2.2 使用同步方法解決

格式:修飾符 synchronized 返回值 方法名(){}

1.2.2.1 案例代碼五:

package com.itheima_05; /** 同步方法:使用關(guān)鍵字synchronized修飾的方法，一旦被一個(gè)線程訪問(wèn)，則整個(gè)方法全部鎖住，其他線程則無(wú)法訪問(wèn)** synchronized* 注意：* 非靜態(tài)同步方法的鎖對(duì)象是this* 靜態(tài)的同步方法的鎖對(duì)象是當(dāng)前類的字節(jié)碼對(duì)象*/ public class TicketThread implements Runnable { static int tickets = 100;// 火車票數(shù)量 Object obj = new Object();@Override public void run() { // 出售火車票 while (true) { /*synchronized (obj) { method(); }*/ //method(); method2();} }private synchronized void method() { if (tickets > 0) {try { Thread.sleep(100); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); }System.out.println(Thread.currentThread().getName() + ":" + tickets--); } } private static synchronized void method2() { if (tickets > 0) {try { Thread.sleep(100); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); }System.out.println(Thread.currentThread().getName() + ":" + tickets--); } }} package com.itheima_05;public class TicktetTest { public static void main(String[] args) { //創(chuàng)建線程對(duì)象 TicketThread tt = new TicketThread(); Thread t = new Thread(tt); t.setName("窗口1"); Thread t2 = new Thread(tt); t2.setName("窗口2"); Thread t3 = new Thread(tt); t3.setName("窗口3"); //啟動(dòng)線程對(duì)象 t.start(); t2.start(); t3.start(); } }

轉(zhuǎn)載于:https://blog.51cto.com/13587708/2091470

總結(jié)

以上是生活随笔為你收集整理的多线程安全问题产生解决方案的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。