s-day06-synchornized代码块解决线程安全问题
This commit is contained in:
@@ -10,14 +10,12 @@ public class TicketTask implements Runnable{
|
|||||||
while (true) {
|
while (true) {
|
||||||
//如果有票就卖
|
//如果有票就卖
|
||||||
if (ticketCount > 0) {
|
if (ticketCount > 0) {
|
||||||
|
|
||||||
//模拟卖票时间
|
//模拟卖票时间
|
||||||
try {
|
try {
|
||||||
Thread.sleep(50);
|
Thread.sleep(50);
|
||||||
} catch (InterruptedException e) {
|
} catch (InterruptedException e) {
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
}
|
}
|
||||||
|
|
||||||
System.out.println(Thread.currentThread().getName() + "正在卖第" + ticketCount + "张票");
|
System.out.println(Thread.currentThread().getName() + "正在卖第" + ticketCount + "张票");
|
||||||
ticketCount--;
|
ticketCount--;
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
@@ -0,0 +1,28 @@
|
|||||||
|
package com.inmind.thread_safe_sychronized05;
|
||||||
|
|
||||||
|
/*
|
||||||
|
在java中可以使用一个关键字synchronized来解决线程安全问题.
|
||||||
|
|
||||||
|
synchronized能够修饰代码块和方法,修饰代码块之后就被称之为同步代码块,修饰方法之后就被称之为同步方法
|
||||||
|
|
||||||
|
同步代码块语法:
|
||||||
|
synchronized(锁对象){
|
||||||
|
具有线程安全问题的代码
|
||||||
|
}
|
||||||
|
|
||||||
|
同步代码块的作用:只有拥有锁对象的线程才能进入同步代码块去执行,如果没有锁对象的线程
|
||||||
|
就会被阻塞在synchronized关键字处.
|
||||||
|
|
||||||
|
锁对象:可以是java中的任意一个对象.Object String ArrayList.
|
||||||
|
|
||||||
|
注意:在同步代码块中,锁对象不管有多少个线程,它只能是同一个
|
||||||
|
*/
|
||||||
|
public class Demo06 {
|
||||||
|
public static void main(String[] args) {
|
||||||
|
//创建卖票任务
|
||||||
|
TicketTask ticketTask = new TicketTask();
|
||||||
|
new Thread(ticketTask, "窗口1").start();
|
||||||
|
new Thread(ticketTask,"窗口2").start();
|
||||||
|
new Thread(ticketTask,"窗口3").start();
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,29 @@
|
|||||||
|
package com.inmind.thread_safe_sychronized05;
|
||||||
|
|
||||||
|
//卖票任务:就是卖100张票
|
||||||
|
public class TicketTask implements Runnable{
|
||||||
|
int ticketCount = 100;//100张票
|
||||||
|
Object lock = new Object();//锁对象
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void run() {
|
||||||
|
//有票就卖
|
||||||
|
while (true) {
|
||||||
|
synchronized (lock){//这里是3个线程共享的同一个锁对象
|
||||||
|
//如果有票就卖
|
||||||
|
if (ticketCount > 0) {
|
||||||
|
//模拟卖票时间
|
||||||
|
try {
|
||||||
|
Thread.sleep(50);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
|
System.out.println(Thread.currentThread().getName() + "正在卖第" + ticketCount + "张票");
|
||||||
|
ticketCount--;
|
||||||
|
} else {
|
||||||
|
break;//结束循环
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user