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

          大盤預(yù)測 國富論
          posted on 2009-06-16 14:50 華夢行 閱讀(567) 評論(0)  編輯  收藏 所屬分類: JDK
          主站蜘蛛池模板: 望江县| 德江县| 龙州县| 睢宁县| 义马市| 监利县| 阳东县| 南充市| 育儿| 马龙县| 红桥区| 天水市| 焉耆| 镶黄旗| 浦东新区| 惠来县| 琼海市| 信宜市| 凤凰县| 东阿县| 彭山县| 涪陵区| 重庆市| 金门县| 广饶县| 布尔津县| 海淀区| 剑河县| 友谊县| 新龙县| 博客| 阿拉尔市| 昭通市| 崇信县| 凉城县| 德安县| 威海市| 靖西县| 盐池县| 青冈县| 德州市|