• 3.1. 异步执行方式

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