Advertisement
Guest User

Untitled

a guest
Apr 17th, 2014
48
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.51 KB | None | 0 0
  1. ListenableFuture<Integer> future = MoreExecutors.listeningDecorator(executor).submit(
  2. new Callable<Integer>() {
  3. @Override
  4. public Integer call() throws Exception {
  5. ...
  6. }
  7. });
  8.  
  9. // Add jobId to the map. You should use a thread-safe Map!
  10. map.put(jobId, future);
  11.  
  12. Futures.addCallback(future, new FutureCallback<Integer>(){
  13. @Override
  14. public void onSuccess(Integer result) {
  15. map.remove(jobId);
  16. ...
  17. }
  18.  
  19. @Override
  20. public void onFailure(Throwable t) {
  21. map.remove(jobId);
  22. ...
  23. }});
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement