import java.util.HashMap;
import java.util.Map;
-import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.ExecutorService;
import org.eclipse.jdt.annotation.NonNullByDefault;
import org.eclipse.jdt.annotation.Nullable;
}
public class CBusThreadPoolExecutor extends CGateThreadPoolExecutor {
- private final ThreadPoolExecutor threadPool;
+ private final ExecutorService threadPool;
public CBusThreadPoolExecutor(@Nullable String poolName) {
- threadPool = (ThreadPoolExecutor) ThreadPoolManager.getPool("binding.cbus-" + poolName);
+ threadPool = ThreadPoolManager.getPool("binding.cbus-" + poolName);
}
@Override