You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2017/05/09 20:02:53 UTC
[24/34] httpcomponents-core git commit: HTTPASYNC-78: replaced
volatile int with AtomicLong in
AbstractMultiworkerIOReactor#DefaultThreadFactory
HTTPASYNC-78: replaced volatile int with AtomicLong in AbstractMultiworkerIOReactor#DefaultThreadFactory
git-svn-id: https://svn.apache.org/repos/asf/httpcomponents/httpcore/branches/4.3.x@1606473 13f79535-47bb-0310-9956-ffa450edef68
Project: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/commit/34244564
Tree: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/tree/34244564
Diff: http://git-wip-us.apache.org/repos/asf/httpcomponents-core/diff/34244564
Branch: refs/heads/4.3.x
Commit: 34244564878eb46e036b271b7435f3d033499352
Parents: 3ccf1e1
Author: Oleg Kalnichevski <ol...@apache.org>
Authored: Sun Jun 29 12:04:56 2014 +0000
Committer: Oleg Kalnichevski <ol...@apache.org>
Committed: Sun Jun 29 12:04:56 2014 +0000
----------------------------------------------------------------------
.../http/impl/nio/reactor/AbstractMultiworkerIOReactor.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/httpcomponents-core/blob/34244564/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/AbstractMultiworkerIOReactor.java
----------------------------------------------------------------------
diff --git a/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/AbstractMultiworkerIOReactor.java b/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/AbstractMultiworkerIOReactor.java
index 426723e..f542989 100644
--- a/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/AbstractMultiworkerIOReactor.java
+++ b/httpcore-nio/src/main/java/org/apache/http/impl/nio/reactor/AbstractMultiworkerIOReactor.java
@@ -40,6 +40,7 @@ import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.ThreadFactory;
+import java.util.concurrent.atomic.AtomicLong;
import org.apache.http.annotation.ThreadSafe;
import org.apache.http.nio.params.NIOReactorPNames;
@@ -596,10 +597,10 @@ public abstract class AbstractMultiworkerIOReactor implements IOReactor {
static class DefaultThreadFactory implements ThreadFactory {
- private static volatile int COUNT = 0;
+ private final static AtomicLong COUNT = new AtomicLong(1);
public Thread newThread(final Runnable r) {
- return new Thread(r, "I/O dispatcher " + (++COUNT));
+ return new Thread(r, "I/O dispatcher " + COUNT.getAndIncrement());
}
}