Experimental: Run I/O after commands in a new thread

common/src/main/java/me/lucko/luckperms/common/commands/SubCommand.java

@@ -162,32 +162,44 @@ public abstract class SubCommand<T> {
     }
 
     public static void save(User user, Sender sender, LuckPermsPlugin plugin) {
-        if (plugin.getDatastore().saveUser(user).getUnchecked()) {
+        plugin.doAsync(() -> {
+            boolean success = plugin.getDatastore().saveUser(user).getUnchecked();
+            user.getRefreshBuffer().request().getUnchecked();
+
+            if (success) {
                 Message.USER_SAVE_SUCCESS.send(sender);
             } else {
                 Message.USER_SAVE_ERROR.send(sender);
             }
+        });
 
-        user.getRefreshBuffer().request().getUnchecked();
     }
 
     public static void save(Group group, Sender sender, LuckPermsPlugin plugin) {
-        if (plugin.getDatastore().saveGroup(group).getUnchecked()) {
+        plugin.doAsync(() -> {
+            boolean success = plugin.getDatastore().saveGroup(group).getUnchecked();
+            plugin.getUpdateTaskBuffer().request().getUnchecked();
+
+            if (success) {
                 Message.GROUP_SAVE_SUCCESS.send(sender);
             } else {
                 Message.GROUP_SAVE_ERROR.send(sender);
             }
+        });
 
-        plugin.getUpdateTaskBuffer().request();
     }
 
     public static void save(Track track, Sender sender, LuckPermsPlugin plugin) {
-        if (plugin.getDatastore().saveTrack(track).getUnchecked()) {
+        plugin.doAsync(() -> {
+            boolean success = plugin.getDatastore().saveTrack(track).getUnchecked();
+            plugin.getUpdateTaskBuffer().request().getUnchecked();
+
+            if (success) {
                 Message.TRACK_SAVE_SUCCESS.send(sender);
             } else {
                 Message.TRACK_SAVE_ERROR.send(sender);
             }
+        });
 
-        plugin.getUpdateTaskBuffer().request();
     }
 }

common/src/main/java/me/lucko/luckperms/common/data/Importer.java

@@ -174,8 +174,10 @@ public class Importer {
     }
 
     private void logMessage(String msg) {
+        if (executing != -1) {
             getResult(executing, "").getOutput().add(Util.stripColor(msg));
         }
+    }
 
     private static class FakeSender implements Sender {
         private final Importer instance;

common/src/main/java/me/lucko/luckperms/common/storage/AbstractDatastore.java

@@ -87,6 +87,11 @@ public class AbstractDatastore implements Datastore {
         backing.doSync(r);
     }
 
+    @Override
+    public Datastore force() {
+        return this;
+    }
+
     @Override
     public void init() {
         backing.init();

common/src/main/java/me/lucko/luckperms/common/storage/Datastore.java

@@ -52,9 +52,7 @@ public interface Datastore {
      */
     void doSync(Runnable r);
 
-    default Datastore force() {
+    Datastore force();
-        return this;
-    }
 
     void init();
     void shutdown();

common/src/main/java/me/lucko/luckperms/common/storage/TolerantDatastore.java

@@ -74,6 +74,11 @@ public class TolerantDatastore implements Datastore {
         backing.doSync(r);
     }
 
+    @Override
+    public Datastore force() {
+        return this;
+    }
+
     @Override
     public void init() {
         backing.init();