9.16. 线程池扩展

服务提供方线程池实现策略,当服务器收到一个请求时,需要在线程池中创建一个线程去执行服务提供方业务逻辑。

扩展接口

org.apache.dubbo.common.threadpool.ThreadPool

扩展配置

<dubbo:protocol threadpool="xxx" />
<!-- 缺省值设置,当<dubbo:protocol>没有配置threadpool时,使用此配置 -->
<dubbo:provider threadpool="xxx" />

已知扩展

  • org.apache.dubbo.common.threadpool.FixedThreadPool
  • org.apache.dubbo.common.threadpool.CachedThreadPool

扩展示例

  • Maven 项目结构:
    src
     |-main
        |-java
            |-com
                |-xxx
                    |-XxxThreadPool.java (实现ThreadPool接口)
        |-resources
            |-META-INF
                |-dubbo
                    |-org.apache.dubbo.common.threadpool.ThreadPool (纯文本文件,内容为:xxx=com.xxx.XxxThreadPool)
    
  • XxxThreadPool.java:
    package com.xxx;
    import org.apache.dubbo.common.threadpool.ThreadPool;
    import java.util.concurrent.Executor;
    public class XxxThreadPool implements ThreadPool {
        public Executor getExecutor() {
            // ...
        }
    }
    
  • META-INF/dubbo/org.apache.dubbo.common.threadpool.ThreadPool:
    xxx=com.xxx.XxxThreadPool
    
下一节:将对象转成字节流,用于网络传输,以及将字节流转为对象,用于在收到字节流数据后还原成对象。