9.1.4. 取消异步调用

通过调用Future.cancel()方法可以非常方便的取消一个异步调用。分布式远程服务允许在三个阶段中任何一个阶段取消异步调用：

  1. 远程调用请求在列队中排队阶段
  2. 远程调用请求已经被分布式远程服务接受，还未发送应答回执，执行尚未开始。
  3. 远程调用请求已经在执行阶段

想要正确的处理第三个阶段，在服务端代码里应该检查Thread.currentThread().isInterrupted()的返回状态。范例如下：

  1. // 远程接口
  2. public interface MyRemoteInterface {
  4.     Long myBusyMethod(Long param1, String param2);
  6. }
  8. // 匹配远程接口的异步接口
  9. @RRemoteAsync(MyRemoteInterface.class)
  10. public interface MyRemoteInterfaceAsync {
  12.     RFuture<Long> myBusyMethod(Long param1, String param2);
  14. }
  16. // 远程接口的实现
  17. public class MyRemoteServiceImpl implements MyRemoteInterface {
  19.    public Long myBusyMethod(Long param1, String param2) {
  20.        for (long i = 0; i < Long.MAX_VALUE; i++) {
  21.            iterations.incrementAndGet();
  22.            if (Thread.currentThread().isInterrupted()) {
  23.                 System.out.println("interrupted! " + i);
  24.                 return;
  25.            }
  26.        }
  27.    }
  29. }
  31. RRemoteService remoteService = redisson.getRemoteService();
  32. ExecutorService executor = Executors.newFixedThreadPool(5);
  33. // 注册远程服务的服务端的同时，通过单独指定的ExecutorService来配置执行线程池
  34. MyRemoteInterface serviceImpl = new MyRemoteServiceImpl();
  35. remoteService.register(MyRemoteInterface.class, serviceImpl, 5, executor);
  37. // 异步调用方法
  38. MyRemoteInterfaceAsync asyncService = remoteService.get(MyRemoteInterfaceAsync.class);
  39. RFuture<Long> future = asyncService.myBusyMethod(1L, "someparam");
  40. // 取消异步调用
  41. future.cancel(true);