From 2ce6041ef86351c568607a7b0e0137a0bcbc970a Mon Sep 17 00:00:00 2001
From: P0nk <ponkcode@gmail.com>
Date: Thu, 20 May 2021 21:00:48 +0200
Subject: [PATCH] Add thread safe wrapper for Invocable

---
 pom.xml                                       |  5 +++
 .../java/scripting/SynchronizedInvocable.java | 39 +++++++++++++++++++
 2 files changed, 44 insertions(+)
 create mode 100644 src/main/java/scripting/SynchronizedInvocable.java

diff --git a/pom.xml b/pom.xml
index b8871f358f..a048a458ed 100644
--- a/pom.xml
+++ b/pom.xml
@@ -41,6 +41,11 @@
             <artifactId>yamlbeans</artifactId>
             <version>1.15</version>
         </dependency>
+        <dependency>
+            <groupId>net.jcip</groupId>
+            <artifactId>jcip-annotations</artifactId>
+            <version>1.0</version>
+        </dependency>
 
         <!-- Logging -->
         <dependency>
diff --git a/src/main/java/scripting/SynchronizedInvocable.java b/src/main/java/scripting/SynchronizedInvocable.java
new file mode 100644
index 0000000000..b318837ce5
--- /dev/null
+++ b/src/main/java/scripting/SynchronizedInvocable.java
@@ -0,0 +1,39 @@
+package scripting;
+
+import net.jcip.annotations.ThreadSafe;
+
+import javax.script.Invocable;
+import javax.script.ScriptException;
+
+/**
+ * Thread safe wrapper around Invocable.
+ * Thread safety is achieved by synchronizing all methods.
+ */
+@ThreadSafe
+public class SynchronizedInvocable implements Invocable {
+    private final Invocable invocable;
+
+    public SynchronizedInvocable(Invocable invocable) {
+        this.invocable = invocable;
+    }
+
+    @Override
+    public synchronized Object invokeMethod(Object thiz, String name, Object... args) throws ScriptException, NoSuchMethodException {
+        return invocable.invokeMethod(thiz, name, args);
+    }
+
+    @Override
+    public synchronized Object invokeFunction(String name, Object... args) throws ScriptException, NoSuchMethodException {
+        return invocable.invokeFunction(name, args);
+    }
+
+    @Override
+    public synchronized <T> T getInterface(Class<T> clasz) {
+        return invocable.getInterface(clasz);
+    }
+
+    @Override
+    public synchronized <T> T getInterface(Object thiz, Class<T> clasz) {
+        return invocable.getInterface(thiz, clasz);
+    }
+}