3.1. 异步执行方式

几乎所有的Redisson对象都实现了一个异步接口,异步接口提供的方法名称与其同步接口的方法名称相互匹配。例如:

  1. // RAtomicLong接口继承了RAtomicLongAsync接口
  2. RAtomicLongAsync longObject = client.getAtomicLong("myLong");
  3. RFuture<Boolean> future = longObject.compareAndSetAsync(1, 401);

异步执行的方法都会返回一个实现了RFuture接口的对象。该对象同时提供了java.util.concurrent.CompletionStagejava.util.concurrent.Future两个异步接口。

  1. future.whenComplete((res, exception) -> {
  2. // ...
  3. });
  4. // 或者
  5. future.thenAccept(res -> {
  6. // 处理返回
  7. }).exceptionally(exception -> {
  8. // 处理错误
  9. });