<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    Dict.CN 在線詞典, 英語學習, 在線翻譯

    都市淘沙者

    荔枝FM Everyone can be host

    統計

    留言簿(23)

    積分與排名

    優秀學習網站

    友情連接

    閱讀排行榜

    評論排行榜

    java nio在多線程環境需注意的問題

    原帖:http://m.tkk7.com/adapterofcoms/archive/2010/03/02/314242.html

    有人說java nio在多線程環境下編程簡直就是個惡夢,其實你如果能把握住java nio API的要領,你就可以將之駕馭. 

    0. 一個 channal 對應一個SelectionKey in the same selector.
    e.g:
    SelectionKey sk=sc.register(selector, SelectionKey.OP_READ, handler);
    sk==sc.register(selector, SelectionKey.OP_WRITE, handler) true?
    selector.select() 每次返回的對同一channal的sk是否相同? 

    1.channel.register(...) may block if invoked concurrently with another registration[another.register(...)] or selection operation[selector.select(...)] involving *****the same selector*****.
    這個是register方法jdk src上的原文,
    e.g:
    如果一個selection thread已經在select方法上等待ing,那么這個時候如果有另一條線程調用channal.register方法的話,那么它將被blocking.

    2.selectionKey.cancel() : The key will be removed from all of the selector's key sets during *****the next selection operation[selector.select(...)]*****.
    may block briefly if invoked concurrently with a cancellation[cancel()] or selection operation[select(...)] involving ***the same selector***.
    這個也是cancel方法jdk src上的原文,
    e.g:
    你先將一個selectionKey.cancel(),然后隨即再channel.register to the same selector,
    在cancel和register之間,如果沒有線程(包括當前線程)進行select操作的話,
    那么 throws java.nio.channels.CancelledKeyException.
    所以 cancel-->select-->re-register.  

    3.if don't remove the current selectedKey from selector.selectedKeys()[Set] 將導致 selector.select(...) not block [may be cpu 100%,specially when client cut the current channel(connection)].
    e.g:
    Iterator<SelectionKey> it=selector.selectedKeys().iterator();
    ...for/while it.hasNext()...
    it.remove();<------*****must do it. or Keys' Set.clear() finally; 

    if remove the current selectedKey from selector.selectedKeys()[Set] but don't sk.interestOps(sk.interestOps()& (~sk.readyOps()));將導致 selector.select(...) not block [select() not block several times, or excepted exception] 

    4.op_write should not be registered to the selector.   [may be cpu100%] 

    5. if involving  wakeup() before select() [wakeup called several times >=1],the next select() not block [not block just once]. 

    盡管以前有些人分析了nio的wakeup性能及not block in linux的bug,但是java nio依然是高效的,那些c/c++的牛人們去看看jre/bin目錄下的nio.dll/nio.so吧,java nio是基于select模型(這個是c/c++中常用網絡編程模型之一)的.

    基于java nio的服務器:mina,girzzly[glassfish],jetty(基于girzzly),tomcat6[可以配置Http11NioProtocol]...

    其中從本人對girzzly,tomcat6的源碼分析來看,它們都還沒有真正發揮出nio異步處理請求的優點,它們的讀寫還都是blocking的雖然使用了selectorPool,此外tomcat6要剝離出socket通信還要花費一定的功夫.而mina卻是符其實,還有bug哦.


     

    posted on 2010-05-29 15:53 都市淘沙者 閱讀(2287) 評論(0)  編輯  收藏 所屬分類: 多線程并發編程

    主站蜘蛛池模板: 亚洲欧洲日产韩国在线| 亚洲国产成人精品无码久久久久久综合 | 久久91亚洲精品中文字幕| 少妇中文字幕乱码亚洲影视| 亚洲va在线va天堂成人| 亚洲黄色免费网址| 亚洲va成无码人在线观看| 亚洲a∨国产av综合av下载| 一区二区在线免费视频| 无码少妇精品一区二区免费动态| 色www永久免费网站| 99re6热视频精品免费观看| 四虎成人免费大片在线| 国产va精品免费观看| 亚州免费一级毛片| 国内大片在线免费看| 久久综合亚洲色HEZYO国产| 亚洲日韩人妻第一页| 亚洲综合色区在线观看| 亚洲一区二区三区四区在线观看| 亚洲精品综合在线影院| 成人无码视频97免费| 毛片免费在线观看网站| 午夜时刻免费入口| 国产亚洲精aa成人网站| 亚洲国产精品综合福利专区| 曰批免费视频播放免费| 久久久久免费看成人影片| 免费看搞黄视频网站| 天天摸天天操免费播放小视频| 中文字幕在亚洲第一在线 | 亚洲精品乱码久久久久久下载| 国产精品亚洲а∨无码播放不卡| 精品在线免费观看| 国产精品二区三区免费播放心| 免费观看的a级毛片的网站| 国产亚洲精品国产| 久久精品国产亚洲av麻豆小说 | 亚洲国产精品无码久久久蜜芽| 亚洲AV无码久久精品狠狠爱浪潮| 亚洲人成未满十八禁网站|