欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Netty源碼分析NioEventLoop初始化線程選擇器創(chuàng)建

 更新時間:2022年03月25日 14:57:00   作者:向南是個萬人迷  
這篇文章主要介紹了Netty源碼分析NioEventLoop初始化線程選擇器創(chuàng)建,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

前文傳送門:NioEventLoop創(chuàng)建

初始化線程選擇器

回到上一小節(jié)的MultithreadEventExecutorGroup類的構造方法:

protected MultithreadEventExecutorGroup(int nThreads, Executor executor, 
                                        EventExecutorChooserFactory chooserFactory, Object... args) {
    //代碼省略
    if (executor == null) {
        //創(chuàng)建一個新的線程執(zhí)行器(1)
        executor = new ThreadPerTaskExecutor(newDefaultThreadFactory());
    }
    //構造NioEventLoop(2)
    children = new EventExecutor[nThreads];
    for (int i = 0; i < nThreads; i ++) {
        boolean success = false;
        try {
            children[i] = newChild(executor, args);
            success = true;
        } catch (Exception e) {
            throw new IllegalStateException("failed to create a child event loop", e);
        } finally {
           //代碼省略
        }
    }
    //創(chuàng)建線程選擇器(3)
    chooser = chooserFactory.newChooser(children);
    //代碼省略
}

我們看第三步, 創(chuàng)建線程選擇器:

chooser = chooserFactory.newChooser(children);

NioEventLoop都綁定一個chooser對象, 作為線程選擇器, 通過這個線程選擇器, 為每一個channel分配不同的線程

我們看到newChooser(children)傳入了NioEventLoop數組

我們跟到DefaultEventExecutorChooserFactory類中的newChooser方法:

public EventExecutorChooser newChooser(EventExecutor[] executors) { 
    if (isPowerOfTwo(executors.length)) { 
        return new PowerOfTowEventExecutorChooser(executors);
    } else {
        return new GenericEventExecutorChooser(executors);
    }
}

這里通過 isPowerOfTwo(executors.length) 判斷NioEventLoop的線程數是不是2的倍數, 然后根據判斷結果返回兩種選擇器對象, 這里使用到java設計模式的策略模式

根據這兩個類的名字不難看出, 如果是2的倍數, 使用的是一種高性能的方式選擇線程, 如果不是2的倍數, 則使用一種比較普通的線程選擇方式

我們簡單跟進這兩種策略的選擇器對象中看一下, 首先看一下PowerOfTowEventExecutorChooser這個類:

private static final class PowerOfTowEventExecutorChooser implements EventExecutorChooser {
    private final AtomicInteger idx = new AtomicInteger();
    private final EventExecutor[] executors;
    PowerOfTowEventExecutorChooser(EventExecutor[] executors) {
        this.executors = executors;
    }
    @Override
    public EventExecutor next() {
        return executors[idx.getAndIncrement() & executors.length - 1];
    }
}

這個類實現了線程選擇器的接口EventExecutorChooser, 構造方法中初始化了NioEventLoop線程數組

重點關注下next()方法, next()方法就是選擇下一個線程的方法, 如果線程數是2的倍數, 這里通過按位與進行計算, 所以效率極高

再看一下GenericEventExecutorChooser這個類:

private static final class GenericEventExecutorChooser implements EventExecutorChooser {
    private final AtomicInteger idx = new AtomicInteger();
    private final EventExecutor[] executors;
    GenericEventExecutorChooser(EventExecutor[] executors) {
        this.executors = executors;
    }
    @Override
    public EventExecutor next() {
        return executors[Math.abs(idx.getAndIncrement() % executors.length)];
    }
}

這個類同樣實現了線程選擇器的接口EventExecutorChooser, 并在造方法中初始化了NioEventLoop線程數組

再看這個類的next()方法, 如果線程數不是2的倍數, 則用絕對值和取模的這種效率一般的方式進行線程選擇

這樣, 我們就初始化了線程選擇器對象

以上就是Netty源碼分析NioEventLoop初始化線程選擇器創(chuàng)建的詳細內容,更多關于Netty線程選擇器NioEventLoop的資料請關注腳本之家其它相關文章!

相關文章

  • Java多線程之鎖的強化學習

    Java多線程之鎖的強化學習

    Java多線程的鎖都是基于對象的,Java中的每一個對象都可以作為一個鎖。這篇文章主要來通過一下示例為大家強化一下鎖的相關知識的掌握,希望對大家有所幫助
    2023-02-02
  • mybatis 為什么千萬不要使用 where 1=1

    mybatis 為什么千萬不要使用 where 1=1

    這篇文章主要介紹了mybatis 為什么千萬不要使用 where 1=1,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2021-05-05
  • Java常見的阻塞隊列總結

    Java常見的阻塞隊列總結

    今天我們來討論另外一類容器:阻塞隊列,文中有非常詳細的代碼示例及介紹,對正在學習JAVA的小伙伴們很有幫助,需要的朋友可以參考下
    2021-06-06
  • Java的@Transactional、@Aysnc、事務同步問題詳解

    Java的@Transactional、@Aysnc、事務同步問題詳解

    這篇文章主要介紹了Java的@Transactional、@Aysnc、事務同步問題詳解,現在我們需要在一個業(yè)務方法中插入一個用戶,這個業(yè)務方法我們需要加上事務,然后插入用戶后,我們要異步的方式打印出數據庫中所有存在的用戶,需要的朋友可以參考下
    2023-11-11
  • jpa異常No entity found for query問題解決

    jpa異常No entity found for query問題解決

    這篇文章主要為大家介紹了jpa異常之No entity found for query的異常問題解決,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步
    2022-03-03
  • spring的TransactionalEventListener事務感知源碼解析

    spring的TransactionalEventListener事務感知源碼解析

    這篇文章主要為大家介紹了spring的TransactionalEventListener事務感知源碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-09-09
  • SpringBoot跨域Jsonp和Cors的方法

    SpringBoot跨域Jsonp和Cors的方法

    這篇文章主要介紹了SpringBoot跨域Jsonp和Cors的方法,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2019-08-08
  • 詳解SpringBoot 發(fā)布ApplicationEventPublisher和監(jiān)聽ApplicationEvent事件

    詳解SpringBoot 發(fā)布ApplicationEventPublisher和監(jiān)聽ApplicationEvent事

    這篇文章主要介紹了詳解SpringBoot 發(fā)布ApplicationEventPublisher和監(jiān)聽ApplicationEvent事件,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2019-06-06
  • java Socket實現簡單模擬HTTP服務器

    java Socket實現簡單模擬HTTP服務器

    這篇文章主要介紹了java Socket實現簡單模擬HTTP服務器,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧
    2017-05-05
  • java瀏覽器文件打包下載過程解析

    java瀏覽器文件打包下載過程解析

    這篇文章主要介紹了java瀏覽器文件打包下載過程解析,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
    2019-10-10

最新評論