X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=netvirt%2Frenderers%2Fneutron%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fnetvirt%2Fnetvirt%2Frenderers%2Fneutron%2FDelegatingDataTreeListener.java;h=fd35781193f45a62ca8fe0a0bffc1ee4b1967a5a;hb=a8d50e95f5d60042ad7ce2067e24aae4d47ee940;hp=ec0c05b53959ff3252abd533b24844c36400d754;hpb=98ef829334faf6b617308f13e487856a43ba23db;p=netvirt.git diff --git a/netvirt/renderers/neutron/src/main/java/org/opendaylight/netvirt/netvirt/renderers/neutron/DelegatingDataTreeListener.java b/netvirt/renderers/neutron/src/main/java/org/opendaylight/netvirt/netvirt/renderers/neutron/DelegatingDataTreeListener.java index ec0c05b539..fd35781193 100644 --- a/netvirt/renderers/neutron/src/main/java/org/opendaylight/netvirt/netvirt/renderers/neutron/DelegatingDataTreeListener.java +++ b/netvirt/renderers/neutron/src/main/java/org/opendaylight/netvirt/netvirt/renderers/neutron/DelegatingDataTreeListener.java @@ -12,7 +12,10 @@ import com.google.common.base.Preconditions; import java.util.Collection; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +import java.util.concurrent.ThreadFactory; import javax.annotation.Nonnull; + +import com.google.common.util.concurrent.ThreadFactoryBuilder; import org.opendaylight.controller.md.sal.binding.api.*; import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.binding.DataObject; @@ -27,7 +30,9 @@ public class DelegatingDataTreeListener implements AutoClo private static final Logger LOG = LoggerFactory.getLogger(DelegatingDataTreeListener.class); protected NeutronProvider provider; protected DataBroker db; - private final ExecutorService executorService = Executors.newFixedThreadPool(1); + private static final ThreadFactory threadFactory = new ThreadFactoryBuilder() + .setNameFormat("NV-NeutronDTL-%d").build(); + private final ExecutorService executorService = Executors.newFixedThreadPool(1, threadFactory); private final DataProcessor dataProcessor; private ListenerRegistration> listenerRegistration;