synchronized單個對象多個線程問題
分析: 當多個線程訪問線程類的run方法時荣瑟,以排隊的方式進行處理(通過cpu安排治拿,而不是通過代碼的順序)
1: 嘗試獲得鎖
2: 如果拿到鎖,執(zhí)行synchronized代碼塊內容笆焰,拿不到鎖劫谅,這個線程就會不斷的嘗試獲得這把鎖,直到拿到為止,這樣會出現(xiàn)多個線程同時去競爭這把鎖捏检。(也就會有鎖競爭問題荞驴,比如上千個線程同時訪問,就會造成cpu使用率一下增加)贯城。
synchronized 多個對象多個線程問題
對于多個多線程多個對象熊楼,如果要實現(xiàn)訪問synchronized修飾的方法,如果實現(xiàn)同時只有一個線程執(zhí)行該方法能犯,需要在該方法加static 鲫骗,此時synchronized屬于類級方法。
public static synchronized void print(String tag){
try{
if (tag.equals("a")) {
num = 100;
System.out.println("tag a 賦值成功");
Thread.sleep(1000);
}else{
num = 200;
System.out.println("tag "+tag+" 賦值成功");
}
System.out.println("tag "+ tag+" num 為"+ num);
}catch(Exception e){
e.printStackTrace();
}
}
volatile
1: volatile 主要修飾變量讓多個線程間透明踩晶,比如执泰,一個變量a = 0,線程A 要把a賦值為10 ,線程B 要把a 賦值為20 渡蜻,當線程A修改成10 之后术吝,線程B還是從0 修改成20 ,如果在變量名前面加上volatile茸苇,數(shù)據(jù)就保持一致性排苍,線程B修改的是a此時為10,讓線程A和B都保持了透明学密。
2: volatile 不具備原子性淘衙。想要變量在多線程中具備原子性,可以使用AtomicInteger
private static volatile int count;
private static AtomicInteger count = new AtomicInteger(0);
private static void addCount(){
for (int i = 0; i < 1000; i++) {
//count++ ;
count.incrementAndGet();
}
System.out.println(count);
}
線程間通信wait则果、notify
wait幔翰、notify 要配合synchronized 使用。wait 是釋放鎖西壮,notify 是獲取鎖遗增。
public static void main(String[] args) {
final ListAdd2 list2 = new ListAdd2();
// 1 實例化出來一個 lock
// 當使用wait 和 notify 的時候 , 一定要配合著synchronized關鍵字去使用
//final Object lock = new Object();
final CountDownLatch countDownLatch = new CountDownLatch(1);
Thread t1 = new Thread(new Runnable() {
@Override
public void run() {
try {
//synchronized (lock) {
for(int i = 0; i <10; i++){
list2.add();
System.out.println("當前線程:" + Thread.currentThread().getName() + "添加了一個元素..");
Thread.sleep(500);
if(list2.size() == 5){
System.out.println("已經(jīng)發(fā)出通知..");
countDownLatch.countDown();
//lock.notify();
}
}
//}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}, "t1");
Thread t2 = new Thread(new Runnable() {
@Override
public void run() {
//synchronized (lock) {
if(list2.size() != 5){
try {
//System.out.println("t2進入...");
//lock.wait();
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("當前線程:" + Thread.currentThread().getName() + "收到通知線程停止..");
throw new RuntimeException();
//}
}
}, "t2");
t2.start();
t1.start();
}
ThreadLocal
ThreadLocal 為了解決多線程下變量的問題款青,一般并發(fā)量不是很高的情況下做修,用synchronized性能比較好,如果是并發(fā)特別高的情況下