001package com.pi4j.concurrent;
002
003/*
004 * #%L
005 * **********************************************************************
006 * ORGANIZATION  :  Pi4J
007 * PROJECT       :  Pi4J :: Java Library (Core)
008 * FILENAME      :  ShutdownDisabledExecutorWrapper.java
009 *
010 * This file is part of the Pi4J project. More information about
011 * this project can be found here:  https://www.pi4j.com/
012 * **********************************************************************
013 * %%
014 * Copyright (C) 2012 - 2021 Pi4J
015 * %%
016 * This program is free software: you can redistribute it and/or modify
017 * it under the terms of the GNU Lesser General Public License as
018 * published by the Free Software Foundation, either version 3 of the
019 * License, or (at your option) any later version.
020 *
021 * This program is distributed in the hope that it will be useful,
022 * but WITHOUT ANY WARRANTY; without even the implied warranty of
023 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
024 * GNU General Lesser Public License for more details.
025 *
026 * You should have received a copy of the GNU General Lesser Public
027 * License along with this program.  If not, see
028 * <http://www.gnu.org/licenses/lgpl-3.0.html>.
029 * #L%
030 */
031
032import java.util.Collection;
033import java.util.List;
034import java.util.concurrent.Callable;
035import java.util.concurrent.ExecutionException;
036import java.util.concurrent.ExecutorService;
037import java.util.concurrent.Future;
038import java.util.concurrent.TimeUnit;
039import java.util.concurrent.TimeoutException;
040
041/**
042 * Wrap an executor service but disable the shutdown method
043 */
044public class ShutdownDisabledExecutorWrapper implements ExecutorService {
045    private ExecutorService executorService;
046
047    public ShutdownDisabledExecutorWrapper(ExecutorService executorService) {
048        this.executorService = executorService;
049    }
050
051    @Override
052    public void shutdown() {
053        throw new UnsupportedOperationException("This scheduled executor service can only be shutdown by Pi4J.");
054    }
055
056    @Override
057    public List<Runnable> shutdownNow() {
058        throw new UnsupportedOperationException("This scheduled executor service can only be shutdown by Pi4J.");
059    }
060
061    @Override
062    public boolean isShutdown() {
063        return executorService.isShutdown();
064    }
065
066    @Override
067    public boolean isTerminated() {
068        return executorService.isTerminated();
069    }
070
071    @Override
072    public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
073        return executorService.awaitTermination(timeout, unit);
074    }
075
076    @Override
077    public <T> Future<T> submit(Callable<T> task) {
078        return executorService.submit(task);
079    }
080
081    @Override
082    public <T> Future<T> submit(Runnable task, T result) {
083        return executorService.submit(task, result);
084    }
085
086    @Override
087    public Future<?> submit(Runnable task) {
088        return executorService.submit(task);
089    }
090
091    @Override
092    public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException {
093        return executorService.invokeAll(tasks);
094    }
095
096    @Override
097    public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException {
098        return executorService.invokeAll(tasks, timeout, unit);
099    }
100
101    @Override
102    public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, ExecutionException {
103        return executorService.invokeAny(tasks);
104    }
105
106    @Override
107    public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
108        return executorService.invokeAny(tasks, timeout, unit);
109    }
110
111    @Override
112    public void execute(Runnable command) {
113        executorService.execute(command);
114    }
115}