多執行緒 CyclicBarrier

public class cyclicbarriertest implements runnable	
@override
public void run() catch (exception e) 
}}

@test
public void testcyclicbarrier() 
try catch (interruptedexception e) 
}

public int await() throws interruptedexception, brokenbarrierexception  catch (timeoutexception toe) 
}

也就是說本質上呼叫的是dowait方法，下面是dowait方法的原始碼

/**
* main barrier code, covering the various policies.
*/private int dowait(boolean timed, long nanos)
throws interruptedexception, brokenbarrierexception,
timeoutexception 
int index = --count;
if (index == 0) finally 
}// loop until tripped, broken, interrupted, or timed out
for (;;) catch (interruptedexception ie) else 
}if (g.broken)
throw new brokenbarrierexception();
if (g != generation)
return index;
if (timed && nanos <= 0l) 
}} finally 
}

在提出問題前，先了解 lock 一波

參考

lock(), 如果獲取了鎖立即返回，如果別的執行緒持有鎖，當前執行緒則一直處於休眠狀態，直到獲取鎖

trylock(), 如果獲取了鎖立即返回true，如果別的執行緒正持有鎖，立即返回false；

trylock(long timeout,timeunit unit)，如果獲取了鎖定立即返回true，如果別的執行緒正持有鎖，會等待引數給定的時間，在等待的過程中，如果獲取了鎖定，就返回true，如果等待超時，返回false；

lockinterruptibly:如果獲取了鎖定立即返回，如果沒有獲取鎖定，當前執行緒處於休眠狀態，直到或者鎖定，或者當前執行緒被別的執行緒中斷

reentrantlock鎖為什麼要定義乙個final的臨時變數來使用，而不是直接使用this.lock？

答：主要是因為為了確保可見性，this.lock是volatile型別，在使用時會需要重新整理快取變數直記憶體，在頻繁使用時有效能損耗。所以用臨時變數接管，可以提高效能。另外乙個原因，對於lock，在方法內的後續操作中是不允許有修改的，所以會定義乙個final型別的臨時變數，其實也就是有點相當於注釋的作用了

此方法是多個執行緒中呼叫的，呼叫此方法表示到達了屏障位置，並且每個執行緒呼叫此方法的時候都是需要通過計數來判斷是否全都到達屏障位置。但方法開始就加了鎖，而計數是在鎖範圍內的**執行的，也就是說應該是只有第乙個呼叫的執行緒才會執行計數，而後呼叫的所有執行緒都應該是拿不到鎖的，那這個計數是怎麼實現的呢？

答：因為鎖有是否重入的分類，剛好reentrantlock是重入鎖。

多執行緒 CyclicBarrier

多執行緒多執行緒原理

多執行緒（一） tomcat 多執行緒

多執行緒理解多執行緒（一）

多執行緒 CyclicBarrier

多執行緒 多執行緒原理

多執行緒（一） tomcat 多執行緒

多執行緒 理解多執行緒（一）

相關推薦

多執行緒多執行緒原理

多執行緒理解多執行緒（一）