如何在Spring Flux中停止昂贵的计算

public Mono<Result> performExpensiveCalculation(CancellationSignal cancellationSignal) {
    // 在计算任务的关键位置，检查Cancellation Signal是否被触发
    if (cancellationSignal.isCancelled()) {
        // 如果Cancellation Signal被触发，则停止计算任务
        return Mono.empty();
    }
    
    // 执行昂贵的计算任务
    // ...
}

// 创建Cancellation Signal对象
CancellationSignal cancellationSignal = new CancellationSignal();

// 启动计算任务
Mono<Result> calculationResult = performExpensiveCalculation(cancellationSignal);

// 在需要停止计算的地方，调用cancel()方法
cancellationSignal.cancel();

Mono<Result> calculationResult = Mono.create(sink -> {
    // 创建Cancellation Signal对象
    CancellationSignal cancellationSignal = new CancellationSignal();
    
    // 在计算任务的关键位置，检查Cancellation Signal是否被触发
    if (cancellationSignal.isCancelled()) {
        // 如果Cancellation Signal被触发，则停止计算任务
        sink.success();
        return;
    }
    
    // 执行昂贵的计算任务
    // ...
    
    // 将计算结果发送给Mono
    sink.success(result);
});

// 在需要停止计算的地方，调用cancel()方法
cancellationSignal.cancel();