File tree Expand file tree Collapse file tree 1 file changed +9
-18
lines changed
agent/storage/src/main/java/me/hsgamer/topper/agent/storage Expand file tree Collapse file tree 1 file changed +9
-18
lines changed Original file line number Diff line number Diff line change 77import me .hsgamer .topper .storage .core .DataStorage ;
88
99import java .util .*;
10- import java .util .concurrent .CompletableFuture ;
1110import java .util .concurrent .ConcurrentLinkedQueue ;
1211import java .util .concurrent .atomic .AtomicBoolean ;
1312import java .util .concurrent .atomic .AtomicReference ;
@@ -66,24 +65,16 @@ private void save(boolean urgent) {
6665 })
6766 .collect (Collectors .toMap (Map .Entry ::getKey , Map .Entry ::getValue ));
6867
69- Runnable saveTask = () -> {
70- try {
71- storage .save (finalMap );
72- if (!removeKeys .isEmpty ()) {
73- storage .remove (removeKeys );
74- }
75- savingMap .set (null );
76- } catch (Throwable t ) {
77- logger .log (Level .SEVERE , "Failed to save entries for " + holder .getName (), t );
78- } finally {
79- saving .set (false );
68+ try {
69+ storage .save (finalMap );
70+ if (!removeKeys .isEmpty ()) {
71+ storage .remove (removeKeys );
8072 }
81- };
82-
83- if (urgent ) {
84- saveTask .run ();
85- } else {
86- CompletableFuture .runAsync (saveTask );
73+ savingMap .set (null );
74+ } catch (Throwable t ) {
75+ logger .log (Level .SEVERE , "Failed to save entries for " + holder .getName (), t );
76+ } finally {
77+ saving .set (false );
8778 }
8879 }
8980
You can’t perform that action at this time.
0 commit comments