public static Future getSuccessFuture()

in core/src/main/java/com/alibaba/smart/framework/engine/util/ParallelGatewayUtil.java [67:84]

• 14 lines of code
• 6 McCabe index (conditional complexity)

    public static Future<PvmActivity> getSuccessFuture(List<Future<PvmActivity>> futureList, boolean skipTimeout) {
        if (null == futureList) {
            return null;
        }

        // 没有抑制超时异常，直接获取第一个即可。
        if (!skipTimeout) {
            return futureList.get(0);
        }

        for (Future<PvmActivity> future : futureList) {
            // DONE且是非取消状态
            if (future.isDone() && !future.isCancelled()) {
                return future;
            }
        }
        return null;
    }