Posted on 2009-10-06 23:56
dennis 閱讀(3514)
評(píng)論(0) 編輯 收藏 所屬分類:
java 、
my open-source
上篇文章我談到了
java nio的一個(gè)嚴(yán)重BUG，并且介紹了jetty是如何規(guī)避這個(gè)BUG的。我在將這部分代碼整合進(jìn)yanf4j的過程中發(fā)現(xiàn)了不少誤判的情況，讓我們看看誤判是怎么發(fā)生的。jetty的解決方案是通過在select返回為0的情況下，計(jì)量Selector.select(timeout)執(zhí)行的時(shí)間是否與傳入的timeout參數(shù)相差太大（小于timeout的一半），如果相差太大，那么認(rèn)為發(fā)生一次bug，如果發(fā)生的次數(shù)超過設(shè)定值，依據(jù)嚴(yán)重程度進(jìn)行處理：第一嘗試取消任何有效并且interestOps等于0的SelectionKey；第二次就是重新創(chuàng)建一個(gè)Selector，并將有效的Channel注冊到新的Selector。誤判的發(fā)生就產(chǎn)生于這個(gè)時(shí)間的計(jì)量上，看javadoc可以發(fā)現(xiàn)它是這樣描述這個(gè)方法的：
This method performs a blocking
selection operation. It
returns only after at least one channel is selected, this selector's
wakeup
method is invoked, or the current thread is interrupted, whichever comes first
意思就是說這個(gè)方法將阻塞select調(diào)用，直到下列三種情況之一發(fā)生才返回：至少一個(gè)channel被選中；同一個(gè)Selector的wakeup方法被調(diào)用；或者調(diào)用所處的當(dāng)前線程被中斷。這三種情況無論誰先發(fā)生，都將導(dǎo)致select(timeout)返回。因此為了減少誤判，你需要將這三種情況加入判斷條件。Jetty的方案已經(jīng)將select返回為0的情況考慮了，但是卻沒有考慮線程被中斷或者Selector被wakeup的情況，在jetty的運(yùn)行時(shí)也許不會(huì)有這兩種情況的發(fā)生，不過我在windows上用jdk 6u7跑jetty的時(shí)候就發(fā)現(xiàn)了誤判的日志產(chǎn)生。除了wakeup和線程中斷這兩種情形外，為了進(jìn)一步提高判斷效率，應(yīng)該將操作系統(tǒng)版本和jdk版本考慮進(jìn)來，如果是非linux系統(tǒng)直接不進(jìn)行后續(xù)的判斷，如果是jdk6u4以后版本也直接忽略判斷，因此yanf4j里的實(shí)現(xiàn)大致如下：
boolean seeing = false;
/**
* 非linux系統(tǒng)或者超過java6u4版本，直接返回
*/
if (!SystemUtils.isLinuxPlatform()
|| SystemUtils.isAfterJava6u4Version()) {
return seeing;
}
/**
* 判斷是否發(fā)生BUG的要素：
* (1)select返回為0
* (2)wait時(shí)間大于0
* (3)select耗時(shí)小于一定值
* (4)非wakeup喚醒
* (5)非線程中斷引起
*/
if (JVMBUG_THRESHHOLD > 0 && selected == 0
&& wait > JVMBUG_THRESHHOLD && now - before < wait / 4
&& !this.wakenUp.get() /* waken up */
&& !Thread.currentThread().isInterrupted()/* Interrupted */) {
this.jvmBug.incrementAndGet();
其中判斷是否是線程中斷引起的是通過Thread.currentThread().isInterrupted()，判斷是否是wakeup是通過一個(gè)原子變量wakenUp，當(dāng)調(diào)調(diào)用Selector.wakeup時(shí)候，這個(gè)原子變量更新為true。判斷操作系統(tǒng)和jdk版本是通過System.getProperty得到系統(tǒng)屬性做字符串處理即可。類似的代碼示例：
public static final String OS_NAME = System.getProperty("os.name");
private static boolean isLinuxPlatform = false;
static {
if (OS_NAME != null && OS_NAME.toLowerCase().indexOf("linux") >= 0) {
isLinuxPlatform = true;
}
}
public static final String JAVA_VERSION = System
.getProperty("java.version");
private static boolean isAfterJava6u4Version = false;
static {
if (JAVA_VERSION != null) {
// java4 or java5
if (JAVA_VERSION.indexOf("1.4.") >= 0
|| JAVA_VERSION.indexOf("1.5.") >= 0)
isAfterJava6u4Version = false;
// if it is java6,check sub version
else if (JAVA_VERSION.indexOf("1.6.") >= 0) {
int index = JAVA_VERSION.indexOf("_");
if (index > 0) {
String subVersionStr = JAVA_VERSION.substring(index + 1);
if (subVersionStr != null && subVersionStr.length() > 0) {
try {
int subVersion = Integer.parseInt(subVersionStr);
if (subVersion >= 4)
isAfterJava6u4Version = true;
} catch (NumberFormatException e) {
}
}
}
// after java6
} else
isAfterJava6u4Version = true;
}
}