lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
Redkale
2020-11-12 09:08:15 +08:00
parent 66bd1feadf
commit 245d6d6fc7
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/org/redkale/mq/MessageAgent.java
View File

@@ -169,7 +169,7 @@ public abstract class MessageAgent {
if (this.sncpProducer == null) { if (this.sncpProducer == null) {
synchronized (sncpProducerLock) { synchronized (sncpProducerLock) {
if (this.sncpProducer == null) { if (this.sncpProducer == null) {
MessageProducer[] producers = new MessageProducer[Runtime.getRuntime().availableProcessors()]; MessageProducer[] producers = new MessageProducer[2];
for (int i = 0; i < producers.length; i++) { for (int i = 0; i < producers.length; i++) {
MessageProducer producer = createProducer("SncpProducer"); MessageProducer producer = createProducer("SncpProducer");
producer.startup().join(); producer.startup().join();
@@ -186,7 +186,7 @@ public abstract class MessageAgent {
if (this.httpProducer == null) { if (this.httpProducer == null) {
synchronized (httpProducerLock) { synchronized (httpProducerLock) {
if (this.httpProducer == null) { if (this.httpProducer == null) {
MessageProducer[] producers = new MessageProducer[Runtime.getRuntime().availableProcessors()]; MessageProducer[] producers = new MessageProducer[2];
for (int i = 0; i < producers.length; i++) { for (int i = 0; i < producers.length; i++) {
MessageProducer producer = createProducer("HttpProducer"); MessageProducer producer = createProducer("HttpProducer");
producer.startup().join(); producer.startup().join();