private static final int MAX_Request = 10000;
    private static final LinkedBlockingQueue<StudentProductCustomPermissionValueBO> requestQueue = new LinkedBlockingQueue<>(MAX_Request);


    @PreDestroy
    @Scheduled(fixedDelay = 1000)
    public void onTick() {
        if (requestQueue.isEmpty()) {
            return;
        }
        List<StudentProductCustomPermissionValueBO> requests = new ArrayList<>(requestQueue.size());
        requestQueue.drainTo(requests);
        save(requests);
    }

    public void offer(StudentProductCustomPermissionValueBO request) {
        while (!requestQueue.offer(request)) {
            // 如果队列满了，进行批量处理
            onTick();
        }
    }

    private void save(List<StudentProductCustomPermissionValueBO> requests) {

        Map<Integer, List<StudentProductCustomPermissionValueBO>> groupBy = requests.stream()
                .collect(Collectors.groupingBy(StudentProductCustomPermissionValueBO::getStudentId));
        for (List<StudentProductCustomPermissionValueBO> rowList : groupBy.values()) {
            StudentProductCustomPermissionValueBO row0 = rowList.get(0);
            Integer studentId = row0.getStudentId();
            Integer productCode = row0.getProductCode();
            String fieldKey = row0.getFieldKey();

            List<String> hexList = rowList.stream()
                    .map(StudentProductCustomPermissionValueBO::getHex)
                    .distinct()
                    .collect(Collectors.toList());

            studentProductCustomPermissionValueService.incrementUsed(
                    studentId,
                    productCode,
                    fieldKey,
                    hexList);
        }
    }