Fixed Bounded executor

This commit is contained in:
Andrea Cavalli 2020-07-10 23:29:22 +02:00
parent ce9fc49cb1
commit a5c8f8f6a5

View File

@ -48,7 +48,7 @@ class BoundedExecutorServiceImpl extends ThreadPoolExecutor implements BoundedEx
*/
@Override
public <T> Future<T> submitButBlockIfFull(final Callable<T> task) throws InterruptedException {
return super.submit(task);
return this.submit(task);
}
/**
@ -57,7 +57,7 @@ class BoundedExecutorServiceImpl extends ThreadPoolExecutor implements BoundedEx
*/
@Override
public void executeButBlockIfFull(final Runnable task) throws InterruptedException {
super.execute(task);
this.execute(task);
}
private void blockIfFull() throws InterruptedException {