X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fconfig%2Fthreadpool-config-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fthreadpool%2Futil%2FNamingThreadPoolFactory.java;h=0efa4824aeb1a029f8d1ff301a09320f95f661d4;hp=608d3a5dfd93263bb1986391108e6671a3dab0e4;hb=refs%2Fchanges%2F02%2F83802%2F42;hpb=9dbad6e87ea28714c4268605927ae64f04443bd3 diff --git a/opendaylight/config/threadpool-config-impl/src/main/java/org/opendaylight/controller/config/threadpool/util/NamingThreadPoolFactory.java b/opendaylight/config/threadpool-config-impl/src/main/java/org/opendaylight/controller/config/threadpool/util/NamingThreadPoolFactory.java index 608d3a5dfd..0efa4824ae 100644 --- a/opendaylight/config/threadpool-config-impl/src/main/java/org/opendaylight/controller/config/threadpool/util/NamingThreadPoolFactory.java +++ b/opendaylight/config/threadpool-config-impl/src/main/java/org/opendaylight/controller/config/threadpool/util/NamingThreadPoolFactory.java @@ -5,43 +5,39 @@ * terms of the Eclipse Public License v1.0 which accompanies this distribution, * and is available at http://www.eclipse.org/legal/epl-v10.html */ - package org.opendaylight.controller.config.threadpool.util; -import com.google.common.base.Preconditions; +import static java.util.Objects.requireNonNull; + import java.io.Closeable; -import java.io.IOException; import java.util.concurrent.ThreadFactory; import java.util.concurrent.atomic.AtomicLong; -import javax.annotation.concurrent.ThreadSafe; /** - * Implementation of {@link ThreadFactory}. + * Implementation of {@link ThreadFactory}. This class is thread-safe. */ -@ThreadSafe public class NamingThreadPoolFactory implements ThreadFactory, Closeable { private final ThreadGroup group; private final String namePrefix; private final AtomicLong threadName = new AtomicLong(); - public NamingThreadPoolFactory(String namePrefix) { - Preconditions.checkNotNull(namePrefix); + public NamingThreadPoolFactory(final String namePrefix) { + this.namePrefix = requireNonNull(namePrefix); this.group = new ThreadGroup(namePrefix); - this.namePrefix = namePrefix; } @Override - public Thread newThread(Runnable r) { + @SuppressWarnings("checkstyle:parameterName") + public Thread newThread(final Runnable r) { return new Thread(group, r, String.format("%s-%d", group.getName(), threadName.incrementAndGet())); } @Override - public void close() throws IOException { + public void close() { } public String getNamePrefix() { return namePrefix; } - }