ChomeNS/chomens-bot-java
3
1
Fork 2
Code Issues Pull requests Projects Releases Packages Wiki Activity

lazy fix

Browse source
This commit is contained in:
Chayapak 2023-07-07 17:10:22 +07:00
parent 78eac00461
commit 07187e7b75
1 changed files with 10 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
src/main/java/land/chipmunk/chayapak/chomens_bot/util/PersistentDataUtilities.java
View file

@ -6,10 +6,7 @@ import com.google.gson.JsonObject;
import land.chipmunk.chayapak.chomens_bot.Main; import land.chipmunk.chayapak.chomens_bot.Main;
import java.io.*; import java.io.*;
import java.util.ArrayList;
import java.util.ConcurrentModificationException; import java.util.ConcurrentModificationException;
import java.util.List;
import java.util.concurrent.TimeUnit;
public class PersistentDataUtilities { public class PersistentDataUtilities {
public static final File file = new File("persistent.json"); public static final File file = new File("persistent.json");
@ -18,8 +15,6 @@ public class PersistentDataUtilities {
public static JsonObject jsonObject = new JsonObject(); public static JsonObject jsonObject = new JsonObject();
private static final List<String> queue = new ArrayList<>();
static { static {
init(); init();
} }
@ -39,41 +34,24 @@ public class PersistentDataUtilities {
} }
writer = new FileWriter(file, false); writer = new FileWriter(file, false);
// i already use ExecutorService so is a queue optional?
Main.executor.scheduleAtFixedRate(() -> {
if (queue.isEmpty()) return;
if (queue.size() > 50) queue.clear();
write(queue.get(0));
queue.remove(0);
}, 0, 1, TimeUnit.SECONDS);
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
while (true) {
if (queue.isEmpty()) break;
}
}));
} catch (IOException e) { } catch (IOException e) {
e.printStackTrace(); e.printStackTrace();
} }
} }
private static synchronized void write (String object) { private static synchronized void write () {
try { try {
final String stringifiedJsonObject = jsonObject.toString();
writer.close(); writer.close();
// ? how do i clear the file contents without making a completely new FileWriter // ? how do i clear the file contents without making a completely new FileWriter
// or is this the only way? // or is this the only way?
writer = new FileWriter(file, false); writer = new FileWriter(file, false);
writer.write(object); writer.write(stringifiedJsonObject);
writer.flush(); writer.flush();
} catch (IOException | ConcurrentModificationException e) { } catch (IOException | ConcurrentModificationException ignored) {}
e.printStackTrace();
}
} }
public static synchronized void put (String property, JsonElement value) { public static synchronized void put (String property, JsonElement value) {
@ -81,7 +59,7 @@ public class PersistentDataUtilities {
if (jsonObject.has(property)) jsonObject.remove(property); if (jsonObject.has(property)) jsonObject.remove(property);
jsonObject.add(property, value); jsonObject.add(property, value);
queue.add(jsonObject.toString()); write();
}); });
} }
@ -90,7 +68,7 @@ public class PersistentDataUtilities {
if (jsonObject.has(property)) jsonObject.remove(property); if (jsonObject.has(property)) jsonObject.remove(property);
jsonObject.addProperty(property, value); jsonObject.addProperty(property, value);
queue.add(jsonObject.toString()); write();
}); });
} }
@ -99,7 +77,7 @@ public class PersistentDataUtilities {
if (jsonObject.has(property)) jsonObject.remove(property); if (jsonObject.has(property)) jsonObject.remove(property);
jsonObject.addProperty(property, value); jsonObject.addProperty(property, value);
queue.add(jsonObject.toString()); write();
}); });
} }
@ -108,7 +86,7 @@ public class PersistentDataUtilities {
if (jsonObject.has(property)) jsonObject.remove(property); if (jsonObject.has(property)) jsonObject.remove(property);
jsonObject.addProperty(property, value); jsonObject.addProperty(property, value);
queue.add(jsonObject.toString()); write();
}); });
} }
@ -117,7 +95,7 @@ public class PersistentDataUtilities {
if (jsonObject.has(property)) jsonObject.remove(property); if (jsonObject.has(property)) jsonObject.remove(property);
jsonObject.addProperty(property, value); jsonObject.addProperty(property, value);
queue.add(jsonObject.toString()); write();
}); });
} }
} }