public class JobRequestExecutor<T> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
JobRequestExecutor.JobRequestType |
Constructor and Description |
---|
JobRequestExecutor(JobRequestExecutor.JobRequestType requestType,
String concurrentRequestsConfigName,
String jobTimeoutConfigName) |
JobRequestExecutor(JobRequestExecutor.JobRequestType requestType,
String concurrentRequestsConfigName,
String jobTimeoutConfigName,
boolean enableCancelTask) |
Modifier and Type | Method and Description |
---|---|
T |
execute(JobCallable<T> jobExecuteCallable) |
boolean |
isThreadPoolEnabled() |
public JobRequestExecutor(JobRequestExecutor.JobRequestType requestType, String concurrentRequestsConfigName, String jobTimeoutConfigName, boolean enableCancelTask)
public JobRequestExecutor(JobRequestExecutor.JobRequestType requestType, String concurrentRequestsConfigName, String jobTimeoutConfigName)
public boolean isThreadPoolEnabled()
public T execute(JobCallable<T> jobExecuteCallable) throws InterruptedException, TimeoutException, TooManyRequestsException, ExecutionException
Copyright © 2021 The Apache Software Foundation. All rights reserved.