package org.opendaylight.yangtools.util.concurrent;
-import java.util.concurrent.Callable;
-import java.util.concurrent.CountDownLatch;
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;
/**
* Some common test utilities.
public interface Invoker {
ListenableFuture<?> invokeExecutor( ListeningExecutorService executor,
CountDownLatch blockingLatch );
- };
+ }
public static final Invoker SUBMIT_CALLABLE = new Invoker() {
@Override
return executor.submit( new Callable<Void>() {
@Override
public Void call() throws Exception {
- if( blockingLatch != null ) {
+ if (blockingLatch != null ) {
Uninterruptibles.awaitUninterruptibly( blockingLatch );
}
return null;
return executor.submit( new Runnable() {
@Override
public void run() {
- if( blockingLatch != null ) {
+ if (blockingLatch != null ) {
Uninterruptibles.awaitUninterruptibly( blockingLatch );
}
}
return executor.submit( new Runnable() {
@Override
public void run() {
- if( blockingLatch != null ) {
+ if (blockingLatch != null ) {
Uninterruptibles.awaitUninterruptibly( blockingLatch );
}
}