This is an automated email from the ASF dual-hosted git repository. liujun pushed a commit to branch 2.6.3-release in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
commit 47a4876a77823694464975251c8a163ad29d364e Author: ken.lj <ken.lj...@gmail.com> AuthorDate: Thu Jul 26 10:17:51 2018 +0800 Merge #2114 mannually from master, enable configuration of Consumer thread pool. --- .../com/alibaba/dubbo/config/ConsumerConfig.java | 48 ++++++++++++++++++++++ .../alibaba/dubbo/config/ConsumerConfigTest.java | 28 +++++++++++++ 2 files changed, 76 insertions(+) diff --git a/dubbo-config/dubbo-config-api/src/main/java/com/alibaba/dubbo/config/ConsumerConfig.java b/dubbo-config/dubbo-config-api/src/main/java/com/alibaba/dubbo/config/ConsumerConfig.java index fcf96de..a16ec93 100644 --- a/dubbo-config/dubbo-config-api/src/main/java/com/alibaba/dubbo/config/ConsumerConfig.java +++ b/dubbo-config/dubbo-config-api/src/main/java/com/alibaba/dubbo/config/ConsumerConfig.java @@ -31,6 +31,18 @@ public class ConsumerConfig extends AbstractReferenceConfig { // networking framework client uses: netty, mina, etc. private String client; + // consumer thread pool type: cached, fixed, limit, eager + private String threadpool; + + // consumer threadpool core thread size + private Integer corethreads; + + // consumer threadpool thread size + private Integer threads; + + // consumer threadpool queue size + private Integer queues; + @Override public void setTimeout(Integer timeout) { super.setTimeout(timeout); @@ -56,4 +68,40 @@ public class ConsumerConfig extends AbstractReferenceConfig { public void setClient(String client) { this.client = client; } + + public String getThreadpool() { + return threadpool; + } + + public void setThreadpool(String threadpool) { + this.threadpool = threadpool; + } + + public Boolean getDefault() { + return isDefault; + } + + public Integer getCorethreads() { + return corethreads; + } + + public void setCorethreads(Integer corethreads) { + this.corethreads = corethreads; + } + + public Integer getThreads() { + return threads; + } + + public void setThreads(Integer threads) { + this.threads = threads; + } + + public Integer getQueues() { + return queues; + } + + public void setQueues(Integer queues) { + this.queues = queues; + } } \ No newline at end of file diff --git a/dubbo-config/dubbo-config-api/src/test/java/com/alibaba/dubbo/config/ConsumerConfigTest.java b/dubbo-config/dubbo-config-api/src/test/java/com/alibaba/dubbo/config/ConsumerConfigTest.java index 4eb2d49..6e288a3 100644 --- a/dubbo-config/dubbo-config-api/src/test/java/com/alibaba/dubbo/config/ConsumerConfigTest.java +++ b/dubbo-config/dubbo-config-api/src/test/java/com/alibaba/dubbo/config/ConsumerConfigTest.java @@ -50,4 +50,32 @@ public class ConsumerConfigTest { consumer.setClient("client"); assertThat(consumer.getClient(), equalTo("client")); } + + @Test + public void testThreadpool() throws Exception { + ConsumerConfig consumer = new ConsumerConfig(); + consumer.setThreadpool("fixed"); + assertThat(consumer.getThreadpool(), equalTo("fixed")); + } + + @Test + public void testCorethreads() throws Exception { + ConsumerConfig consumer = new ConsumerConfig(); + consumer.setCorethreads(10); + assertThat(consumer.getCorethreads(), equalTo(10)); + } + + @Test + public void testThreads() throws Exception { + ConsumerConfig consumer = new ConsumerConfig(); + consumer.setThreads(20); + assertThat(consumer.getThreads(), equalTo(20)); + } + + @Test + public void testQueues() throws Exception { + ConsumerConfig consumer = new ConsumerConfig(); + consumer.setQueues(5); + assertThat(consumer.getQueues(), equalTo(5)); + } }