From 4079893ea4678d4650fe79e4a42abec4a93aeae4 Mon Sep 17 00:00:00 2001
From: Brianna <bri@songoda.com>
Date: Wed, 25 Mar 2020 09:06:41 -0400
Subject: [PATCH] Added the ability to create a private thread.

---
 .../core/database/DataManagerAbstract.java    | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git a/Core/src/main/java/com/songoda/core/database/DataManagerAbstract.java b/Core/src/main/java/com/songoda/core/database/DataManagerAbstract.java
index 604f70d6..3da3c3af 100644
--- a/Core/src/main/java/com/songoda/core/database/DataManagerAbstract.java
+++ b/Core/src/main/java/com/songoda/core/database/DataManagerAbstract.java
@@ -7,12 +7,18 @@ import java.sql.Connection;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
 
 public class DataManagerAbstract {
 
     protected final DatabaseConnector databaseConnector;
     protected final Plugin plugin;
 
+    private static Map<String, ScheduledExecutorService> threads = new HashMap<>();
+
     public DataManagerAbstract(DatabaseConnector databaseConnector, Plugin plugin) {
         this.databaseConnector = databaseConnector;
         this.plugin = plugin;
@@ -55,10 +61,21 @@ public class DataManagerAbstract {
 
     /**
      * Queue a task to be run synchronously.
-     * 
+     *
      * @param runnable task to run on the next server tick
      */
     public void sync(Runnable runnable) {
         Bukkit.getScheduler().runTask(this.plugin, runnable);
     }
+
+    /**
+     * Queue a task to be run synchronously on a new thread.
+     *
+     * @param runnable  task to run on the next server tick
+     * @param threadKey the thread key to run on.
+     */
+    public void sync(Runnable runnable, String threadKey) {
+        threads.computeIfAbsent(threadKey.toUpperCase(),
+                t -> Executors.newSingleThreadScheduledExecutor()).execute(runnable);
+    }
 }