package com.itheima_03;
public class TicketThread implements Runnable {
int tickets = 100;//火車票數量
@Override
public void run() {
//出售火車票
while(true) {
//當火車票小於0張，則停止售票
if(tickets > 0) {
/*
 * t1,t2,t3
 * 假設只剩一張票
 * t1過來了，他一看有票，他就進來了，但是他突然肚子不舒服，然後他就去上衛生間了
 * t2也過來了，他一看也有票，他也進來了，但是他的肚子也不舒服，他也去上衛生間了
 *
 * t1上完了衛生間回來了，開始售票
 * tickets = 0;
 * t2也上完衛生間回來了，他也進行售票
 *  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 多線程安全問題解決
1.2.1 使用同步代碼塊解決

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

1.2.1.1 案例代碼四:

  package com.itheima_04;
/*
 * 問題出現的原因：
 * 要有多個線程
 * 要有被多個線程所共享的數據
 * 多個線程並發的訪問共享的數據
 *
 * 在火車上上廁所
 * 張三來了，一看門是綠的，他就進去了，把門鎖上了，門就變紅了
 * 李四來了，一看門市紅色的，他就只能憋著
 * 張三用完了廁所，把鎖打開了，門就變成了綠色
 * 李四一看門變綠了，他就進去了，把門鎖上，門就變紅了
 * 王五來了，一看們是紅色的，他也只能憋著
 * 李四用完測試了，把鎖打開了，肚子又不舒服了，扭頭回去了，又把門鎖上了，
 *
 * synchronized:同步（鎖），可以修飾代碼塊和方法，被修飾的代碼塊和方法一旦被某個線程訪問，則直接鎖住，其他的線程將無法訪問
 *
 * 同步代碼塊：
 * synchronized(鎖對象){
 *
 * }
 *
 * 註意：鎖對象需要被所有的線程所共享
 *
 *
 * 同步：安全性高，效率低
 * 非同步：效率高，但是安全性低
 *
 */
public class TicketThread implements Runnable {
int tickets = 100;//火車票數量
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) {
//創建線程對象
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");
//啟動線程對象
t.start();
t2.start();
t3.start();
}
}
 

1.2.2 使用同步方法解決

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

}

1.2.2.1 案例代碼五:

package com.itheima_05;
/*
 * 同步方法:使用關鍵字synchronized修飾的方法，一旦被一個線程訪問，則整個方法全部鎖住，其他線程則無法訪問
 *
 * synchronized
 * 註意：
 * 非靜態同步方法的鎖對象是this
 * 靜態的同步方法的鎖對象是當前類的字節碼對象
 */
public class TicketThread implements Runnable {
static int tickets = 100;// 火車票數量
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) {
//創建線程對象
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");
//啟動線程對象
t.start();
t2.start();
t3.start();
}
}

多線程安全問題產生&解決方案