1）Sun的JVM在實(shí)現(xiàn)Selector上，在Linux和Windows平臺(tái)下的細(xì)節(jié)。 2）Selector類的wakeup()方法如何喚醒阻塞在select()系統(tǒng)調(diào)用上的細(xì)節(jié)。 先給大家做一個(gè)簡(jiǎn)單的回顧，在Windows下，Sun的Java虛擬機(jī)在Selector.open()時(shí)會(huì)自己和自己建立loopback的TCP鏈接；在Linux下，Selector會(huì)創(chuàng)建pipe。這主要是為了Selector.wakeup()可以方便喚醒阻塞在select()系統(tǒng)調(diào)用上的線程（通過向自己所建立的TCP鏈接和管道上隨便寫點(diǎn)什么就可以喚醒阻塞線程） 我們知道，無(wú)論是建立TCP鏈接還是建立管道都會(huì)消耗系統(tǒng)資源，而在Windows上，某些Windows上的防火墻設(shè)置還可能會(huì)導(dǎo)致Java的Selector因?yàn)榻⒉黄餷oopback的TCP鏈接而出現(xiàn)異常。 而在我的另一篇文章《用GDB調(diào)試Java程序》中介紹了另一個(gè)Java的解釋器——GNU的gij，以及編譯器gcj，不但可以比較高效地運(yùn)行Java程序，而且還可以把Java程序直接編譯成可執(zhí)行文件。 GNU的之所以要重做一個(gè)Java的編譯和解釋器，其一個(gè)重要原因就是想解釋Sun的JVM的效率和資源耗費(fèi)問題。當(dāng)然，GNU的Java編譯/解釋器并不需要考慮太多復(fù)雜的平臺(tái)，他們只需要專注于Linux和衍生自Unix System V的操作系統(tǒng)，對(duì)于開發(fā)人員來說，離開了Windows，一切都會(huì)變得簡(jiǎn)單起來。在這里，讓我們看看GNU的gij是如何解釋Selector.open()和Selector.wakeup()的。 同樣，我們需要一個(gè)測(cè)試程序。在這里，為了清晰，我不會(huì)例出所有的代碼，我只給出我所使用的這個(gè)程序的一些關(guān)鍵代碼。 我的這個(gè)測(cè)試程序中，和所有的Socket程序一樣，下面是一個(gè)比較標(biāo)準(zhǔn)的框架，當(dāng)然，這個(gè)框架應(yīng)該是在一個(gè)線程中，也就是一個(gè)需要繼承Runnable接口，并實(shí)現(xiàn)run()方法的一個(gè)類。（注意：其中的s是一個(gè)成員變量，是Selector類型，以便主線程序使用） //生成一個(gè)偵聽端 ServerSocketChannel ssc = ServerSocketChannel.open(); //將偵聽端設(shè)為異步方式 ssc.configureBlocking(false); //生成一個(gè)信號(hào)監(jiān)視器 s = Selector.open(); //偵聽端綁定到一個(gè)端口 ssc.socket().bind(new InetSocketAddress(port)); //設(shè)置偵聽端所選的異步信號(hào)OP_ACCEPT ssc.register(s,SelectionKey.OP_ACCEPT); System.out.println("echo server has been set up ......"); while(true){ int n = s.select(); if (n == 0) { //沒有指定的I/O事件發(fā)生 continue; } Iterator it = s.selectedKeys().iterator(); while (it.hasNext()) { SelectionKey key = (SelectionKey) it.next(); if (key.isAcceptable()) { //偵聽端信號(hào)觸發(fā) …… …… …… …… …… …… } if (key.isReadable()) { //某socket可讀信號(hào) …… …… …… …… …… …… } it.remove(); } } 而在主線程中，我們可以通過Selector.wakeup()來喚醒這個(gè)阻塞在select()上的線程，下面是寫在主線程中的喚醒程序： new Thread(this).start(); try{ //Sleep 30 seconds Thread.sleep(30000); System.out.println("wakeup the select"); s.wakeup(); }catch(Exception e){ e.printStackTrace(); } 這個(gè)程序在主線程中，先啟動(dòng)一個(gè)線程，也就是上面那個(gè)Socket線程，然后休息30秒，為的是讓上面的那個(gè)線程有阻塞在select()，然后打印出一條信息，這是為了我們用strace命令查看具體的系統(tǒng)調(diào)用時(shí)能夠快速定位。之后調(diào)用的是Selector的wakeup()方法來喚醒偵聽線程。 接下來，我們可以通過兩種方式來編譯這個(gè)程序： 1）使用gcj或是sun的javac編譯成class文件，然后使用gij解釋執(zhí)行。 2）使用gcj直接編譯成可執(zhí)行文件。 （無(wú)論你用那種方法，都是一樣的結(jié)果，本文使用第二種方法，關(guān)于gcj的編譯方法，請(qǐng)參看我的《用GDB調(diào)試Java程序》） 編譯成可執(zhí)行文件后，執(zhí)行程序時(shí)，使用lsof命令，我們可以看到?jīng)]有任何pipe的建立?？梢奊NU的解釋更為的節(jié)省資源。而對(duì)于一個(gè)Unix的C程序員來說，這意味著如果要喚醒select()只能使用pthread_kill()來發(fā)送一個(gè)信號(hào)了。下面就讓我們使用strace命令來驗(yàn)證這個(gè)想法。 下圖是使用strace命令來跟蹤整個(gè)程序運(yùn)行時(shí)的系統(tǒng)調(diào)用，我們利用我們的輸出的“wakeup the select”字符串快速的找到了wakeup的實(shí)際系統(tǒng)調(diào)用。

大盤預(yù)測(cè) 國(guó)富論