add #82

Author: xlorne

flow-engine-framework/src/main/java/com/codingapi/flow/mock/MockInstance.java

@@ -3,13 +3,14 @@
 import com.codingapi.flow.query.FlowRecordQueryService;
 import com.codingapi.flow.service.FlowService;
 import lombok.Getter;
-import lombok.extern.slf4j.Slf4j;
 
 import java.util.Timer;
 import java.util.TimerTask;
 
 
-@Slf4j
+/**
+ *  模拟实例对象，当MockInstance被创建以后若15分钟没人操作，则将会自动注销，当有人操作会持续延长15分钟的时间。
+ */
 public class MockInstance {
 
     @Getter
@@ -23,11 +24,14 @@ public class MockInstance {
 
     private final Timer timer;
 
+    @Getter
     private final long createTime;
 
+    @Getter
     private long expiredTime;
 
-    private static final long MAX_KEEP_TIME = 1000 * 60 * 30;
+    // 最大活跃时长，15分钟
+    private static final long MAX_KEEP_TIME = 1000 * 60 * 15;
 
     public MockInstance(String mockKey, MockRepositoryHolder repositoryHolder, FlowService flowService, FlowRecordQueryService flowRecordQueryService) {
         this.mockKey = mockKey;
@@ -44,12 +48,18 @@ public void updateExpiredTime(){
         this.expiredTime = System.currentTimeMillis() + MAX_KEEP_TIME;
     }
 
+    /**
+     * 是否到期
+     */
+    public boolean isExpired(){
+        return System.currentTimeMillis() > expiredTime;
+    }
+
     private void initTimer() {
         this.timer.scheduleAtFixedRate(new TimerTask() {
             @Override
             public void run() {
-                long currentTime = System.currentTimeMillis();
-                if (expiredTime > currentTime) {
+                if (isExpired()) {
                     MockInstanceFactory.getInstance().clear(mockKey);
                     timer.cancel();
                     return;

flow-engine-framework/src/main/java/com/codingapi/flow/mock/MockInstanceFactory.java

@@ -1,14 +1,17 @@
 package com.codingapi.flow.mock;
 
 import com.codingapi.flow.gateway.FlowOperatorGateway;
-import com.codingapi.flow.mock.server.FlowRecordQueryMockService;
+import com.codingapi.flow.mock.service.FlowRecordQueryMockService;
 import com.codingapi.flow.service.FlowService;
 import com.codingapi.flow.utils.RandomUtils;
 import lombok.Getter;
 
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
+/**
+ * 模拟示例构建工厂
+ */
 public class MockInstanceFactory {
 
     private final Map<String, MockInstance> cache;

flow-engine-framework/src/main/java/com/codingapi/flow/mock/MockRepositoryHolder.java

@@ -18,6 +18,9 @@
 
 import java.util.List;
 
+/**
+ * 模拟仓库持有者对象
+ */
 @Getter
 public class MockRepositoryHolder implements IRepositoryHolder {
 

…k/server/FlowRecordQueryMockService.java …/service/FlowRecordQueryMockService.javaflow-engine-framework/src/main/java/com/codingapi/flow/mock/server/FlowRecordQueryMockService.java renamed to flow-engine-framework/src/main/java/com/codingapi/flow/mock/service/FlowRecordQueryMockService.java flow-engine-framework/src/main/java/com/codingapi/flow/mock/server/FlowRecordQueryMockService.java renamed to flow-engine-framework/src/main/java/com/codingapi/flow/mock/service/FlowRecordQueryMockService.java

@@ -1,4 +1,4 @@
-package com.codingapi.flow.mock.server;
+package com.codingapi.flow.mock.service;
 
 import com.codingapi.flow.mock.MockRepositoryHolder;
 import com.codingapi.flow.mock.repository.FlowRecordRepositoryMockImpl;