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 <[email protected]> Authored: Tue Jan 5 16:25:47 2016 +0530 Committer: Isuru Haththotuwa <[email protected]> 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()); } }
