多流水线并发调用Windows可用盘符方法时重复分配问题求助

核心问题是多流水线并行调用getAvailableDrive时，检查可用盘符和返回盘符之间存在竞态条件——多个流水线同时查到同一个可用盘符，导致重复分配。要解决这个问题，关键是让盘符分配的逻辑串行执行，同一时间只有一个流水线能执行检查和分配操作。

以下是几种可行的解决方案：

方案1：用Jenkins Pipeline的lock步骤加全局锁 #

这是最直接的方案，利用Jenkins内置的lock步骤，确保盘符分配逻辑同一时间只能被一个流水线执行。

修改共享库中的getAvailableDrive.groovy，将核心逻辑包裹在lock块内：

#!groovy

def call(){
    // 用固定名称的全局锁，确保所有流水线竞争同一把锁
    lock('WindowsDriveAllocation') {
        def drivesInfo=bat(script: '@echo off && fsutil fsinfo drives', returnStdout: true).trim()
        usedDrives=drivesInfo.substring(8).tokenize(" ")
        def drivesList=[]
        for(alpha = 'A'; alpha <= 'Z'; ++alpha){
            drivesList.add("${alpha}:\\")
        }
        usedDrives.each{
            if(drivesList.contains("${it}"))
                drivesList.remove("${it}")
        }
        if(drivesList.isEmpty())
            throw new Exception("No unused Drive/s Found!")
        return drivesList[0].take(2)
    }
}

• 原理：lock步骤会创建全局互斥锁，所有需要分配盘符的流水线必须等待锁释放后才能执行内部逻辑，彻底避免并行检查导致的重复分配。
• 注意：锁名称要唯一，确保所有调用该方法的流水线都使用同一把锁。

方案2：绑定到单个执行器执行分配逻辑 #

如果不想用全局锁，也可以指定让盘符分配逻辑只在节点的某个特定执行器上运行，利用执行器的串行特性实现互斥。

修改方法，先切换到指定执行器再执行分配：

#!groovy

def call(){
    // 指定当前节点的执行器编号（比如执行器0），确保只有这个执行器处理分配
    node(env.NODE_NAME) {
        executor(0) {
            def drivesInfo=bat(script: '@echo off && fsutil fsinfo drives', returnStdout: true).trim()
            usedDrives=drivesInfo.substring(8).tokenize(" ")
            def drivesList=[]
            for(alpha = 'A'; alpha <= 'Z'; ++alpha){
                drivesList.add("${alpha}:\\")
            }
            usedDrives.each{
                if(drivesList.contains("${it}"))
                    drivesList.remove("${it}")
            }
            if(drivesList.isEmpty())
                throw new Exception("No unused Drive/s Found!")
            return drivesList[0].take(2)
        }
    }
}

• 原理：通过executor步骤指定固定执行器，同一执行器同一时间只能处理一个任务，自然实现串行分配。
• 注意：需要确认目标节点确实存在该编号的执行器，且该执行器未被其他独占任务占用。

方案3：分配后立即占用盘符（可选补充） #

为进一步避免非Jenkins进程占用刚分配的盘符，可以在返回盘符前创建临时占位标记，确保盘符被识别为已用：

#!groovy

def call(){
    lock('WindowsDriveAllocation') {
        def drivesInfo=bat(script: '@echo off && fsutil fsinfo drives', returnStdout: true).trim()
        usedDrives=drivesInfo.substring(8).tokenize(" ")
        def drivesList=[]
        for(alpha = 'A'; alpha <= 'Z'; ++alpha){
            drivesList.add("${alpha}:\\")
        }
        usedDrives.each{
            if(drivesList.contains("${it}"))
                drivesList.remove("${it}")
        }
        if(drivesList.isEmpty())
            throw new Exception("No unused Drive/s Found!")
        
        def selectedDrive = drivesList[0].take(2)
        // 创建临时目录标记盘符为已用
        bat(script: "mkdir ${selectedDrive}\\jenkins_temp_lock", returnStatus: true)
        return selectedDrive
    }
}

• 提示：流水线结束后记得删除临时目录jenkins_temp_lock，释放盘符供后续使用。

内容的提问来源于stack exchange，提问作者R_SS