guava-libraries exampleに基づいて、ListenableFuture を使用しています。
私は使用しています:
Java 1.6
JDeveloper 11.1.1.6.0 guava
-13.0.1.jar
junit-4.5.jar
easymock-3.1.jar
powermock-easymock-1.4.12-full.jar
テスト中のメソッドが非同期モードで呼び出されるようにしようとしています。
私の Manager.java コードは次のとおりです。
...
public synchronized void refreshAsync(final String id) {
m_Log.entry(id);
ListeningExecutorService service =
MoreExecutors.listeningDecorator(Executors.newCachedThreadPool());
ListenableFuture<Details> getDetailsTask =
service.submit(new Callable<Details>() {
@Override
public Details call() {
System.out.println(Thread.currentThread().toString());
return MyCacheManager.getDetails(id);
}
});
Futures.addCallback(getDetailsTask ,
new FutureCallback<Details>() {
// we want this handler to run immediately after we push the big red button!
public void onSuccess(Details details) {
System.out.println("Success");
//TODO: publish event
}
public void onFailure(Throwable thrown) {
System.out.println("Failed");
//TODO: log
}
});
service.shutdown();
m_Log.exit("done async");
}
...
私のテストは次のとおりです。
@RunWith(PowerMockRunner.class)
@PrepareForTest( { Manager.class, MyCacheManager.class, TWResourceManager.class, Logger.class })
public class DetailsTests {
{
...
@Test (timeout = 4000)
public void refreshAsync_RequestedInAsyncMode_NoWaitForComplete() throws Exception {
// Creating nice mock - because we are not caring about methods call order
mockStatic(MyCacheManager.class);
// Setup
final int operationTimeMilis = 5000;
expect(MyCacheManager.getDetails(anyObject(String.class))).andStubAnswer(new IAnswer<Details>() {
public Details answer() {
try {
System.out.println("start waiting 5 sec");
System.out.println(Thread.currentThread().toString());
Thread.sleep(operationTimeMilis);
System.out.println("finished waiting 5 sec");
} catch (InterruptedException e) {
e.printStackTrace();
}
return Details.getEmpty();
}
});
replay(MyCacheManager.class);
replayAll();
ISchemaActionsContract controller = new TWManager();
controller.refreshSchemaDetailsAsync("schema_id");
// We need not to verify mocks, since all we are testing is timeout
// verifyAll();
}
}
テストを実行/デバッグしているとき-タイムアウトで常に失敗します。モックされたメソッド「MyCacheManager.getDetails」が「同期」モードで呼び出されているようです。
しかし、通常のコード/デバッグから同じ関数を呼び出すと、非同期モードで実行されます (Thread.sleep(10000) を MyCacheManager.getDetails メソッドに入れ、Manager.refreshAsync メソッドは待機せずに終了します/ブロックされます.
また、通常の FutureTask を使用するようにメソッドを変更している場合、テストは期待どおりにパスします。
...
Object res = null;
FutureTask task = new FutureTask(new Runnable() {
@Override
public void run() {
MyCacheManager.getDetails(id);
}
}, res);
m_Log.debug("async mode - send request and do not wait for answer.");
Executors.newCachedThreadPool().submit(task);
どんなアイデアでも大歓迎です!:)
ありがとう!