import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.Uninterruptibles;
-import java.util.concurrent.Callable;
import java.util.concurrent.CountDownLatch;
/**
* @author Thomas Pantelis
*/
public class CommonTestUtils {
-
+ @FunctionalInterface
public interface Invoker {
- ListenableFuture<?> invokeExecutor( ListeningExecutorService executor,
- CountDownLatch blockingLatch );
+ ListenableFuture<?> invokeExecutor(ListeningExecutorService executor, CountDownLatch blockingLatch);
}
- public static final Invoker SUBMIT_CALLABLE = (executor, blockingLatch) -> executor.submit(new Callable<Void>() {
- @Override
- public Void call() throws Exception {
- if (blockingLatch != null ) {
- Uninterruptibles.awaitUninterruptibly( blockingLatch );
- }
- return null;
+ public static final Invoker SUBMIT_CALLABLE = (executor, blockingLatch) -> executor.submit(() -> {
+ if (blockingLatch != null) {
+ Uninterruptibles.awaitUninterruptibly(blockingLatch);
}
- } );
+ return null;
+ });
public static final Invoker SUBMIT_RUNNABLE = (executor, blockingLatch) -> executor.submit(() -> {
- if (blockingLatch != null ) {
- Uninterruptibles.awaitUninterruptibly( blockingLatch );
+ if (blockingLatch != null) {
+ Uninterruptibles.awaitUninterruptibly(blockingLatch);
}
});
public static final Invoker SUBMIT_RUNNABLE_WITH_RESULT = (executor, blockingLatch) -> executor.submit(() -> {
- if (blockingLatch != null ) {
- Uninterruptibles.awaitUninterruptibly( blockingLatch );
+ if (blockingLatch != null) {
+ Uninterruptibles.awaitUninterruptibly(blockingLatch);
}
- }, "foo" );
+ }, "foo");
}