懵逼， controller 中两个接口调用 service 同一方法，方法中有递归操作，前端一个页面异步调用这两个接口，后端出现线程问题

cantroller 层 @PostMapping("/traffic/records") public List listTrafficRecord() { List doorRecordInfoVOList = doorApiService.doorRecordList(null); return doorRecordInfoVOList.stream() .limit(3) .collect(Collectors.toList());

@GetMapping("/visitor/record") public List listVisitorRecord() { List doorRecordInfoVOList = doorApiService.doorRecordList("4"); return doorRecordInfoVOList.stream() .limit(2) .collect(Collectors.toList()); } service 实现

public List<DoorRecordInfoVO> doorRecordList(String typeFlag) {
    reentrantLock.lock();
    try {
        //首先获取 token
        String token = this.getToken();
        if (StrUtil.isEmpty(token)) {
            return null;
        }
        List<DoorRecordInfoVO> doorRecordInfoVOList = new ArrayList<>();
        LocalDateTime now = LocalDateTime.now();
        LocalDateTime start = now.minusHours(12L);
        return handleList(doorRecordInfoVOList, now, start, token, typeFlag, 0);
    }finally {
        reentrantLock.unlock();
    }
}

private List<DoorRecordInfoVO> handleList(List<DoorRecordInfoVO> doorRecordInfoVOList,
                                          LocalDateTime now,
                                          LocalDateTime start,
                                          String token,
                                          String typeFlag,
                                          int retryCount) {
    //判断两个时间是不是在同一天
    if (now.toLocalDate().equals(start.toLocalDate())) {
        //在同一天组装时间范围
        String date = now.format(DateTimeFormatter.ofPattern("yyyyMMdd"));
        String startTime = start.format(DateTimeFormatter.ofPattern("HHmmss"));
        String endTime = now.format(DateTimeFormatter.ofPattern("HHmmss"));
        JSONArray recordArray = this.apiResult(token, date, startTime, endTime);
        this.addArrayToList(recordArray, doorRecordInfoVOList, typeFlag);
    } else {
        //不在同一天
        String date = now.format(DateTimeFormatter.ofPattern("yyyyMMdd"));
        String endTime = now.format(DateTimeFormatter.ofPattern("HHmmss"));
        JSONArray recordArray1 = this.apiResult(token, date, "000000", endTime);
        this.addArrayToList(recordArray1, doorRecordInfoVOList, typeFlag);
        //加上前一天时间段
        String preDate = start.format(DateTimeFormatter.ofPattern("yyyyMMdd"));
        String startTime = start.format(DateTimeFormatter.ofPattern("HHmmss"));
        JSONArray recordArray2 = this.apiResult(token, preDate, startTime, "235959");
        this.addArrayToList(recordArray2, doorRecordInfoVOList, typeFlag);
    }
    if (doorRecordInfoVOList.size() < 3) {
        now = start;
        start = start.minusHours(1L);
        handleList(doorRecordInfoVOList, now, start, token, typeFlag, retryCount + 1);
    }
    return doorRecordInfoVOList;
}


private void addArrayToList(JSONArray array, List<DoorRecordInfoVO> doorRecordInfoVOList, String typeFlag) {
    if (ObjectUtil.isEmpty(array)) return;
    for (int i = 0; i < array.size(); i++) {
        JSONObject record = array.getJSONObject(i);
        DoorRecordInfoVO doorRecordInfoVO = new DoorRecordInfoVO();
        String type = record.getStr("recogResult");
        doorRecordInfoVO.setUserName(record.getStr("userName"));
        doorRecordInfoVO.setDoorName(record.getStr("doorName"));
        doorRecordInfoVO.setOpenTime(
                HcDateUtil.dateFormat(record.getStr("openTime"), "yyyyMMddHHmmss", "yyyy-MM-dd HH:mm:ss")
        );
        doorRecordInfoVO.setRecordType(type);
        if (StrUtil.isNotEmpty(typeFlag) && typeFlag.equals(type)) {
            doorRecordInfoVOList.add(doorRecordInfoVO);
        } else if (StrUtil.isEmpty(typeFlag)) {
            doorRecordInfoVOList.add(doorRecordInfoVO);
        }
    }
}

private JSONArray apiResult(String token, String date, String startTime, String endTime) {
    JSONArray jsonArray = null;
    //组装请求参数
    Map<String, Object> requestMap = new HashMap<>();
    Map<String, Object> map = new HashMap<>();

    map.put("beginTime", startTime);
    map.put("endTime", endTime);
    map.put("date", date);

    requestMap.put("data", map);
    //调用 api 获取数据
    String body = HttpRequest
            .post(getDoorRecordInfoUrl)
            .header("token", token)
            .header("appId", appId)
            .header("Content-Type", "application/json")
            .body(JSONUtil.toJsonStr(requestMap))
            .execute()
            .body();
    JSONObject resultJson = JSONUtil.parseObj(body);
    Integer code = resultJson.getInt("code");
    if (code == 200) {
        JSONObject data = resultJson.getJSONObject("data");
        jsonArray = data.getJSONArray("data");
    }
    return jsonArray;
}

上述实现如果我不加上 reentrantLock ，doorRecordInfoVOList 线程安全问题，有一个接口直接返回空了，但是直接分开调用，都有返回，请问这个为啥会有线程安全问题，求大佬指教

fordes

347 天前

后端出现线程问题可能是因为在 doorRecordList()服务方法中使用了全局的 ReentrantLock 对象（ reentrantLock ），而在 Controller 层中有两个接口同时调用此服务方法。

当一个线程进入 doorRecordList()方法并获取锁之后，如果此时另一个线程也试图通过另一个接口调用该方法获取锁，由于锁已经被占用，第二个线程将会被阻塞，直到第一个线程执行完方法体内的逻辑并释放锁。在高并发场景下，如果前端页面异步同时调用这两个接口，可能会导致线程争抢锁资源，从而影响系统性能和响应速度。

另外，handleList() 方法内部递归调用自身时，每次递归都会尝试获取锁，这也会增加线程同步的复杂性。特别是在递归过程中涉及到网络 IO 操作（如 apiResult()方法中的 HTTP 请求），可能导致线程长时间持有锁而不释放，进而影响其他线程的执行。

为了解决这个问题，可以考虑以下策略：

确认是否需要在整个方法上加锁，根据业务需求看是否能将锁的作用范围缩小至实际有共享数据竞争的部分。
如果确实需要全局锁来保证数据一致性，可以考虑使用信号量或者条件变量等更细粒度的同步机制，以减少线程间的相互阻塞。
对于 HTTP 请求这类耗时操作，尽量避免在同步代码块或持有锁的情况下进行，可以通过异步处理、多线程池等方式提高并发能力。
总之，在设计并发访问的方法时，应确保正确合理地管理锁，避免造成不必要的线程阻塞，提高系统的并发处理能力和响应速度。

(通义千问的回答)