You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2018/07/26 02:18:12 UTC
[incubator-dubbo] 02/02: Merge #2114 mannually from master,
enable configuration of Consumer thread pool.
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 <ke...@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));
+ }
}