You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by is...@apache.org on 2016/01/05 16:47:57 UTC
[48/50] [abbrv] stratos git commit: using a AtomicInteger in
StratosThreadFactory to count threads
using a AtomicInteger in StratosThreadFactory to count threads
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/4ef0b6ea
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/4ef0b6ea
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/4ef0b6ea
Branch: refs/heads/stratos-4.1.x
Commit: 4ef0b6eada68c4c42d7fe90ebb45bbc29b9e5631
Parents: 8088240
Author: Isuru Haththotuwa <is...@apache.org>
Authored: Tue Jan 5 16:25:47 2016 +0530
Committer: Isuru Haththotuwa <is...@apache.org>
Committed: Tue Jan 5 16:25:47 2016 +0530
----------------------------------------------------------------------
.../apache/stratos/common/threading/StratosThreadFactory.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/4ef0b6ea/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/threading/StratosThreadFactory.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/threading/StratosThreadFactory.java b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/threading/StratosThreadFactory.java
index 98ddd37..476d20c 100644
--- a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/threading/StratosThreadFactory.java
+++ b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/threading/StratosThreadFactory.java
@@ -20,17 +20,18 @@
package org.apache.stratos.common.threading;
import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.atomic.AtomicInteger;
public class StratosThreadFactory implements ThreadFactory {
private String prefix;
- private int counter;
+ private final AtomicInteger threadNumber;
public StratosThreadFactory(String prefix) {
this.prefix = prefix;
- this.counter = 0;
+ this.threadNumber = new AtomicInteger(1);
}
public Thread newThread(Runnable r) {
- return new Thread(r, prefix + "-" + (++counter));
+ return new Thread(r, prefix + "-" + threadNumber.getAndIncrement());
}
}