public void writeFlush()

in src/main/java/com/aliyun/openservices/paifeaturestore/dao/FeatureViewFeatureDBDao.java [707:729]

• 22 lines of code
• 5 McCabe index (conditional complexity)

    public void writeFlush() {
        lock.lock();
        try {
            if (writeData.size() > 0) {
                try {
                    doWriteFeatures();
                    this.executor.shutdown();
                    try {
                        if (!this.executor.awaitTermination(5, TimeUnit.SECONDS)) {
                            this.executor.shutdownNow(); // 取消正在执行的任务
                        }
                    } catch (InterruptedException e) {
                        this.executor.shutdownNow();
                    }

                } catch (Exception e) {
                    log.error(String.format("request featuredb error:%s", e.getMessage()));
                }
            }
        } finally {
            lock.unlock();
        }
    }