Added async events

swnck · Feb 28, 2024 · a915112 · a915112
1 parent 77f3880
commit a915112
Show file tree

Hide file tree

Showing 2 changed files with 32 additions and 3 deletions.
diff --git a/src/main/java/at/jkvn/eventlib/EventLib.java b/src/main/java/at/jkvn/eventlib/EventLib.java
@@ -18,27 +18,43 @@
 import java.util.Arrays;
 import java.util.Comparator;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 
 @Getter
 public class EventLib {
     @Getter
     private static Configuration configuration;
     @Getter
     private static final List<Listener> listeners = new ArrayList<>();
+    @Getter
+    private static final ExecutorService executor = Executors.newCachedThreadPool();
 
     @SneakyThrows
     public static void call(Event event) {
         if (isAutomatic()) {
-            invokeMethods(getMethods(), event);
+            invokeMethods(getMethods(), event, false);
+            return;
+        }
+
+        (new ArrayList<>(listeners)).forEach(listener -> {
+            invokeMethods(Arrays.stream(listener.getClass().getMethods()).toList(), event, false);
+        });
+    }
+
+    @SneakyThrows
+    public static void callAsync(Event event) {
+        if (isAutomatic()) {
+            invokeMethods(getMethods(), event, true);
             return;
         }
 
         (new ArrayList<>(listeners)).forEach(listener -> {
-            invokeMethods(Arrays.stream(listener.getClass().getMethods()).toList(), event);
+            invokeMethods(Arrays.stream(listener.getClass().getMethods()).toList(), event, true);
         });
     }
 
-    private static void invokeMethods(List<Method> methods, Event event) {
+    private static void invokeMethods(List<Method> methods, Event event, boolean async) {
         methods.stream()
                 .filter(method -> method.getParameterCount() == 1
                         && method.getParameterTypes()[0].isAssignableFrom(event.getClass()))
@@ -47,6 +63,10 @@ private static void invokeMethods(List<Method> methods, Event event) {
                     return priority != null ? priority.value().ordinal() : EventPriority.NORMAL.ordinal();
                 }))
                 .forEach(method -> {
+                    if (async)  {
+                        executor.execute(() -> invokeSafely(method, event));
+                        return;
+                    }
                     invokeSafely(method, event);
                 });
     }

diff --git a/src/test/java/TestProject.java b/src/test/java/TestProject.java
@@ -51,6 +51,15 @@ public void call() {
         assertTrue(dummyEvent.wasCalled());
     }
 
+    @Test
+    public void callAsync() {
+        DummyEvent dummyEvent = new DummyEvent();
+
+        EventLib.callAsync(dummyEvent);
+
+        assertTrue(dummyEvent.wasCalled());
+    }
+
     @EventHandler
     public void onDummyEvent(DummyEvent event) {
         event.call();