X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fconfig%2Fthreadpool-config-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fthreadpool%2Futil%2FNamingThreadPoolFactory.java;h=0efa4824aeb1a029f8d1ff301a09320f95f661d4;hb=refs%2Fchanges%2F02%2F83802%2F42;hp=2e27d6cce86115477b5fc255dc4a043d737ec207;hpb=4f76ea30ad49331ca38ce63925b3fabf8e769731;p=controller.git 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 2e27d6cce8..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,45 +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 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; - -import com.google.common.base.Preconditions; - /** - * 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; } - }