From e94ab3dd58a01902310d512179b6702837240e87 Mon Sep 17 00:00:00 2001 From: Robert Varga Date: Tue, 4 Jul 2023 21:51:57 +0200 Subject: [PATCH] Use Futures.submit() Do not wrap the ExecutorService and just use Futures.submit() to arrive at a ListenableFuture with any executor. Change-Id: Id43ba68f65aa7a358159024364515f8029b95d5f Signed-off-by: Robert Varga --- .../controller/sample/kitchen/impl/KitchenServiceImpl.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java b/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java index a40fe5e9ff..55b56741af 100644 --- a/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java +++ b/opendaylight/md-sal/samples/toaster-consumer/src/main/java/org/opendaylight/controller/sample/kitchen/impl/KitchenServiceImpl.java @@ -11,10 +11,10 @@ import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableList.Builder; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; -import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; import java.util.List; import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import javax.annotation.PreDestroy; import javax.inject.Inject; @@ -57,7 +57,7 @@ public final class KitchenServiceImpl extends AbstractMXBean private static final Logger LOG = LoggerFactory.getLogger(KitchenServiceImpl.class); private static final MakeToastOutput EMPTY_MAKE_OUTPUT = new MakeToastOutputBuilder().build(); - private final ListeningExecutorService executor = MoreExecutors.listeningDecorator(Executors.newCachedThreadPool()); + private final ExecutorService executor = Executors.newCachedThreadPool(); private final ToasterService toaster; private final Registration reg; @@ -115,7 +115,7 @@ public final class KitchenServiceImpl extends AbstractMXBean } private ListenableFuture> makeEggs(final EggsType eggsType) { - return executor.submit(() -> RpcResultBuilder.success().build()); + return Futures.submit(() -> RpcResultBuilder.success().build(), executor); } private ListenableFuture> makeToast(final ToastType toastType, final int toastDoneness) { -- 2.36.6