flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java
/**
	 * Tests that the {@link AkkaRpcService} can execute runnables
	 */
Tests that the  AkkaRpcService can execute runnables
Tests that the AkkaRpcService can execute runnables
@Test
	public void testExecuteRunnable() throws Exception {
		final OneShotLatch latch = new OneShotLatch();
		akkaRpcService.execute(() -> latch.trigger());
		latch.await(30L, TimeUnit.SECONDS);
	}
@ Test public void testExecuteRunnable ( ) throws Exception { final OneShotLatch latch = new OneShotLatch ( ) ; akkaRpcService . execute ( ( ) -> latch . trigger ( ) ) ; latch . await ( 30L , TimeUnit . SECONDS ) ; }
Tests that the {@link AkkaRpcService} can execute runnables
Tests that the { @link AkkaRpcService } can execute runnables