一、三大不安全案例
package day02;
/*** @Author: Grace* @Date: 2023/10/7 12:50* @Description:*/
//不安全的取钱
//两个人去银行取钱,账户
public class UnsafeBank {public static void main(String[] args) {//账户Account account = new Account(100, "结婚基金");
Drawing you = new Drawing(account, 50, "你");Drawing girlFriend = new Drawing(account, 100, "girlFriend");
you.start();girlFriend.start();}
}
//账户
class Account{int money;//余额String name;//卡名
public Account(int money, String name) {this.money = money;this.name = name;}
}
//银行:模拟取款
class Drawing extends Thread{Account account;//账户//取了多少钱int drawingMoney;//现在手里有多少钱int nowMoney;String name;
public Drawing(Account account,int drawingMoney,String name){super(name);this.account=account;this.drawingMoney=drawingMoney;}
//取钱@Overridepublic void run() {//判断有没有钱if(account.money-drawingMoney<0){System.out.println(Thread.currentThread().getName()+"钱不够,取不了");return;}//sleep放大问题的发生性try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}//卡内余额=余额-你取的钱account.money=account.money-drawingMoney;//你手里的钱nowMoney = nowMoney+drawingMoney;
System.out.println(account.name+"余额为:"+account.money);//Thread.currentThread().getName()=this.getName();System.out.println(this.getName()+"手里的钱:"+nowMoney);}
}
package day02;
/*** @Author: Grace* @Date: 2023/10/7 12:41* @Description:*/
//不安全的买票
//线程不安全有负数
public class UnSafeBuyTicket {public static void main(String[] args) {BuyTicket buyTicket = new BuyTicket();
new Thread(buyTicket,"苦逼得我").start();new Thread(buyTicket,"牛逼的你们").start();new Thread(buyTicket,"可恶的黄牛党").start();}
}
class BuyTicket implements Runnable{
//票private int ticketNums =10;boolean flag = true; //外部停止方式@Overridepublic void run() {//买票while (flag){buy();}}private void buy(){//判断是否有票if(ticketNums<=0){flag=false;return;}//模拟延时try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}//买票System.out.println(Thread.currentThread().getName()+"拿到"+ticketNums--);}
}
package day02;
import java.util.ArrayList;
import java.util.List;
/*** @Author: Grace* @Date: 2023/10/7 13:07* @Description:*/
//线程不安全的集合
public class UnsafeList {public static void main(String[] args) {List<String> list = new ArrayList<>();for (int i = 0; i < 10000; i++) {new Thread(()->{list.add(Thread.currentThread().getName());}).start();}try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}System.out.println(list.size());}
}
二、同步方法
-
由于我们可以通过private关键字来保证数据对象只能被方法访问,所以我们只需要针对方法提出一套机制,这套机制就是synchronized关键字,它包括两种用法:synchronized方法和synchronized块
同步方法:public synchronized void method(int args){}
-
synchronized方法控制对“对象”的访问,每个对象对应一把锁,每个synchronized方法都必须获得调用该方法的对象的锁才能执行,否则线程会阻塞,方法一旦执行,就独占该锁,直到该方法返回才释放锁,后面被阻塞的线程才能获得这个锁,继续执行
缺陷:若将一个大的方法申明为synchronized将会影响效率
-
方法里面需要修改的内容才需要锁,锁的太多,浪费资源
三、同步块
-
同步块:synchronized(Obj ){}
-
Obj称之为同步监视器
-
Obj可以是任何对象,但是推荐使用共享资源作为同步监视器
-
同步方法中无需指定同步监视器,因为同步方法的同步监视器就是this,就是这个对象本身,或者是class[反射中讲解]
-
-
同步监视器的执行过程
-
第一个线程访问,锁定同步监视器,执行其中代码
-
第二个线程访问,发现同步监视器被锁定,无法访问
-
第一个线程访问完毕,解锁同步监视器
-
第二个线程访问,发现同步监视器没有锁,然后锁定并访问
-
-
锁的对象就是变化的量,需要增删改的对象
四、CopyOnWriteArrayList
//测试JUC安全类型的集合
public class TestJUC {public static void main(String[] args) {CopyOnWriteArrayList<String> list =new CopyOnWriteArrayList<String>();for (int i = 0; i < 10000; i++) {new Thread(()->{list.add(Thread.currentThread().getName());}).start();}
try {Thread.sleep(3000);} catch (InterruptedException e) {throw new RuntimeException(e);}
System.out.println(list.size());}
}