• 9.1.4. 取消异步调用

    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);