压测程序线程数改为12

chenld · May 18, 2013 · 9ddb1e0 · 9ddb1e0
1 parent b2959d8
commit 9ddb1e0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rocketmq-example/src/main/java/com/alibaba/rocketmq/example/benchmark/Producer.java b/rocketmq-example/src/main/java/com/alibaba/rocketmq/example/benchmark/Producer.java
@@ -41,7 +41,7 @@ private static Message buildMessage(final int messageSize) {
 
 
  public static void main(String[] args) throws MQClientException {
- final int threadCount = args.length >= 1 ? Integer.parseInt(args[0]) : 4;
+ final int threadCount = args.length >= 1 ? Integer.parseInt(args[0]) : 32;
  final int messageSize = args.length >= 2 ? Integer.parseInt(args[1]) : 1024 * 2;
 
  final Message msg = buildMessage(messageSize);