为什么要线程同步?
多线程可以同时运行很多资源,但存在安全隐患。
当多个线程访问一块资源时,会产生一些不是预料中的事。
比如买票,有窗口和柜台,窗口卖票和售票机卖票都会减少票的数量,一共100张票,通过窗口这个方法卖了70张票,售票机
这个方法卖了50张票,他们都在线程中,票最后不是变成负数了?
什么是线程同步?
为了解决这个问题,我们就让其中一方先执行(被同步加锁),什么是锁呢
票是大家都可以访问的公享资源,叫临界资源,阻止别人访问临界资源的叫互斥锁,当用了这个synchronized的时候
要使用的线程就获得了这个锁,别的线程没有这个锁只能等待该线程结束再访问临界资源。
如何使用?
使用方法可以像public 那样修饰方法也可以用synchronized(Object){ 代码块 }的格式
实例:
可以看出产生许多脏数据
package defaul;
public class MySynchronized implements Runnable{
int num = 10;
public static void main(String[] args) {
MySynchronized mS = new MySynchronized();
Thread t1 = new Thread(mS,"线程一");
Thread t2 = new Thread(mS);
Thread t3 = new Thread(mS);
Thread t4 = new Thread(mS);
t1.start();
t2.start();
t3.start();
t4.start();
}
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
if(num > 0){
System.out.println(num--);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
线程同步后
package defaul;
public class MySynchronized implements Runnable{
int num = 10;
public static void main(String[] args) {
MySynchronized mS = new MySynchronized();
Thread t1 = new Thread(mS,"线程一");
Thread t2 = new Thread(mS);
Thread t3 = new Thread(mS);
Thread t4 = new Thread(mS);
t1.start();
t2.start();
t3.start();
t4.start();
}
@Override
public void run() {
// TODO Auto-generated method stub
while(true){
synchronized(this){//线程同步代码块
if(num > 0){
System.out.println(num--);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
}
}
上面代码也可以改成一个方法,然后调用这个方法也是一样的
public synchronized void sell(){
while(true){
//线程同步代码块
if(num > 0){
System.out.println(num--);
try {
Thread.sleep(100);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
@Override
public void run() {
// TODO Auto-generated method stub
sell();
}