Compare commits

...

1 Commits

Author SHA1 Message Date
weishao 95479449f3 nas延迟 2022-08-12 19:01:57 +08:00
1 changed files with 9 additions and 0 deletions

View File

@ -50,6 +50,15 @@ public class RunOnlyHandler extends TextWebSocketHandler {
JSONObject msg = JSON.parseObject(payload);
if (LOG_TYPE.equals(msg.getString(TYPE))) {
String runOnlyResultKey = RUN_ONLY_RESULT_KEY_PREFIX + msg.getString(DATA);
for (int i = 0; i < 20; i++) {
if (!redisHelper.hasKey(runOnlyResultKey)) {
ThreadUtil.sleepSilently(100);
} else {
break;
}
}
String runOnlyResult = redisHelper.get(runOnlyResultKey);
while (CASE_OUTPUT_SEPARATOR.equals(runOnlyResult) && redisHelper.hasKey(runOnlyResultKey)) {
ThreadUtil.sleepSilently(100);