線程池原理分析鎖的深度化

1、線原理分析&線線線原理分析&線線線線線線 是后，有了很大的改善。JDK1.5java.util.concurrentjava.util.concurrent加入給予開發(fā) 開發(fā)并發(fā)程序以及解決并發(fā)問題很大的幫助。這篇文章主要介紹下并發(fā)包下的Executor Executor口雖然作為一個非常舊的接口（JDK1.52004發(fā)布），但是很多程序員對于其中的一些原理。Executor 框 架 的 最 頂 層 實 現(xiàn) 是 oolExecutor 類， Executors 工廠 類 中 提 供ool 、 ool 、 ool 方 法 其 實 也 只 是Executor 框 架 的 最 頂 層 實 現(xiàn) 是 o

2、olExecutor 類， Executors 工廠 類 中 提 供ool 、 ool 、 ool 方 法 其 實 也 只 是 的。 當(dāng)有unitkeepAliveTime時線，如果/ 無限大小jvm自動回ExecutorService newCachedThreool = Executors.newCachedThrefor (i = 0; i 10; i+) temp=ool.execute(new Runnable() publicvoidtry catch(Exceptione)/TODO:handleln(Thread.currentThread().getName() + ,i:

3、+ ool 創(chuàng)建一個可緩存線ool 創(chuàng)建一個定長線ool 創(chuàng)建一個定長線newSingleThreadExecutor 創(chuàng)建一個單線程化的線任務(wù)按照指定順序(FIFOLIFO, , , , , ScheduledExecutorService newScheduledThreool = Executors.newScheduledThrefor (i = 0; i 10; i+) temp=public void run() ln(i:+,3, ExecutorService newFixedThreool = Executors.newFixedThrefor (i = 0; i 10; i

4、+) temp=ool.execute(new Runnable() publicvoidrun()ln(Thread.currentThread().getId() + ,i: + : 線: 線ExecutorServicenewSingleThreadExecutor=Executors.newSingleThreadExecutor(); for (i = 0; i 10; i+) index = i; newSingleThreadExecutor.execute(newRunnable()publicvoid System.out.prln(index:+index); try ca

5、tch (Exceptione)/TODO:handleJava 鎖的深Java 鎖的深任務(wù)的性質(zhì)：CPU 密集型任務(wù)，IO 密集型任務(wù)和混合型任務(wù)。Ncpu+1 個線程的線。IO密集型任務(wù)則由于需要等待IO操作，線程并不是一直在執(zhí)行任務(wù)，則配置盡時CPU。 密Select *for有多種實現(xiàn)(如synchronized重入鎖，也叫做遞歸鎖，指的是同一線程獲得JAVAReentrantLock 和synchronized重publicclassTestimplementsRunnablepublic synchronizedvoidget()ln(name:+Thread.currentThr

6、ead().getName()+get();); publicsynchronized voidset()ln(name:+Thread.currentThread().getName()+CAS稱 CAS稱 publicclassTest02extendsReentrantLocklock=newReentrantLock(); public void get() publics icvoidmain(StringTestss=newTest(); newThread(ss).start(); newThread(ss).start(); newThread(ss).start();publ

7、ic s ic void main(String Testss=newTest(); newThread(ss).start(); newThread(ss).start(); newThread(ss).start(); newThread(ss).start();CAS 算法的過程是這樣：CAS(V,E,N): V 表示要更新的變量，E 表示預(yù)期值，N 表示新V 值等于E V N， 如果V 值和 E 值不同，則說明已經(jīng)有其他線程做了更新，則當(dāng)前線程什么都不做。最后，CAS 返回當(dāng)前V 的真實值。CAS 操作是抱且允許再次嘗試，當(dāng)然也允許失敗的線程放棄操作。基于這樣的原理，CAS操作即使沒有

8、鎖，也可以發(fā)現(xiàn)publicclassTestimplements spublicclassTestimplements spublic Test(SpinLock this.lock=privateAtomicReferencesign=newAtomicReference(); public void lock() Thread current = Thread.currentThread(); while (pareAndSet(null,current)publicvoidunlock()Threadcurrent=Thread.currentThread(); pareAndSet(current, null);Atomicallyincrementsbyonethecurrent*returntheupdatedfor(;)/獲取當(dāng)前current=/設(shè)置期望next=current+pareAndSet，執(zhí)行CAS操作 if (compareAndSet(current, next)/成功后才會返回期望值，否則無線循環(huán) return next;用這個不可重入的自旋鎖去加鎖的時候沒問題，當(dāng)再次調(diào)lock用這個不可重入的自旋鎖去加鎖的時候沒問題，當(dāng)再次調(diào)lock設(shè)置為null 操 時有數(shù)據(jù)庫實現(xiàn)、緩存實現(xiàn)、Zookeeper 分布式鎖parampublicicvoi