synchronized單個對象多個線程問題

分析: 當(dāng)多個線程訪問線程類的run方法時(shí)，以排隊(duì)的方式進(jìn)行處理（通過cpu安排，而不是通過代碼的順序）
1： 嘗試獲得鎖
2： 如果拿到鎖，執(zhí)行synchronized代碼塊內(nèi)容，拿不到鎖，這個線程就會不斷的嘗試獲得這把鎖，直到拿到為止，這樣會出現(xiàn)多個線程同時(shí)去競爭這把鎖。(也就會有鎖競爭問題，比如上千個線程同時(shí)訪問，就會造成cpu使用率一下增加)。

synchronized 多個對象多個線程問題

對于多個多線程多個對象，如果要實(shí)現(xiàn)訪問synchronized修飾的方法，如果實(shí)現(xiàn)同時(shí)只有一個線程執(zhí)行該方法，需要在該方法加static ，此時(shí)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(bǔ)賦值為10 ，線程B 要把a(bǔ) 賦值為20 ，當(dāng)線程A修改成10 之后，線程B還是從0 修改成20 ，如果在變量名前面加上volatile，數(shù)據(jù)就保持一致性，線程B修改的是a此時(shí)為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 實(shí)例化出來一個 lock
    // 當(dāng)使用wait 和 notify 的時(shí)候 ， 一定要配合著synchronized關(guān)鍵字去使用
    //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("當(dāng)前線程：" + 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進(jìn)入...");
                        //lock.wait();
                        countDownLatch.await();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                System.out.println("當(dāng)前線程：" + Thread.currentThread().getName() + "收到通知線程停止..");
                throw new RuntimeException();
            //}
        }
    }, "t2");   
    
    t2.start();
    t1.start();
    
}

ThreadLocal

ThreadLocal 為了解決多線程下變量的問題，一般并發(fā)量不是很高的情況下，用synchronized性能比較好，如果是并發(fā)特別高的情況下