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 - 2019 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}