Skip to content

S
SkyWalking

山不在高_有仙则灵 / SkyWalking
与 Fork 源项目一致

Fork自 apache / SkyWalking

通知 12
Star 0
Fork 2
S
SkyWalking

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

未验证 提交 778b86e1 编写于 作者: B Brandon Fergerson 提交者： GitHub
浏览文件
操作

Update ConsumeDriver.java (#4610) 

spelling fix
上级 2af4552a
显示空白变更内容
内联 并排
Showing with 2 addition and 2 deletion
apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumeDriver.java
浏览文件 @ 778b86e1
...@@ -34,7 +34,7 @@ public class ConsumeDriver<T> implements IDriver { ...@@ -34,7 +34,7 @@ public class ConsumeDriver<T> implements IDriver {
long consumeCycle) { long consumeCycle) {
this(channels, num); this(channels, num);
for (int i = 0; i < num; i++) { for (int i = 0; i < num; i++) {
consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumser." + i + ".Thread", getNewConsumerInstance(consumerClass), consumeCycle); consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumer." + i + ".Thread", getNewConsumerInstance(consumerClass), consumeCycle);
consumerThreads[i].setDaemon(true); consumerThreads[i].setDaemon(true);
} }
} }
...@@ -43,7 +43,7 @@ public class ConsumeDriver<T> implements IDriver { ...@@ -43,7 +43,7 @@ public class ConsumeDriver<T> implements IDriver {
this(channels, num); this(channels, num);
prototype.init(); prototype.init();
for (int i = 0; i < num; i++) { for (int i = 0; i < num; i++) {
consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumser." + i + ".Thread", prototype, consumeCycle); consumerThreads[i] = new ConsumerThread("DataCarrier." + name + ".Consumer." + i + ".Thread", prototype, consumeCycle);
consumerThreads[i].setDaemon(true); consumerThreads[i].setDaemon(true);
} }
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或