- Removed executor service and all uses from CachedDataSource.

src/main/java/fr/xephi/authme/datasource/CacheDataSource.java

@@ -6,15 +6,12 @@ import com.google.common.cache.CacheLoader;
 import com.google.common.cache.LoadingCache;
 import com.google.common.cache.RemovalListener;
 import com.google.common.cache.RemovalNotification;
-import fr.xephi.authme.ConsoleLogger;
 import fr.xephi.authme.cache.auth.PlayerAuth;
 import fr.xephi.authme.cache.auth.PlayerCache;
 import fr.xephi.authme.security.crypts.HashedPassword;
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 
 /**
@@ -22,7 +19,6 @@ import java.util.concurrent.TimeUnit;
 public class CacheDataSource implements DataSource {
 
     private final DataSource source;
-    private final ExecutorService exec;
     private final LoadingCache<String, Optional<PlayerAuth>> cachedAuths;
 
     /**
@@ -32,7 +28,6 @@ public class CacheDataSource implements DataSource {
      */
     public CacheDataSource(DataSource src) {
         this.source = src;
-        this.exec = Executors.newCachedThreadPool();
         this.cachedAuths = CacheBuilder.newBuilder()
             .expireAfterWrite(8, TimeUnit.MINUTES)
             .removalListener(new RemovalListener<String, Optional<PlayerAuth>>() {
@@ -167,25 +162,14 @@ public class CacheDataSource implements DataSource {
 
     @Override
     public synchronized void close() {
-        try {
-            exec.shutdown();
-            exec.awaitTermination(8, TimeUnit.SECONDS);
-        } catch (InterruptedException e) {
-            ConsoleLogger.writeStackTrace("Error while closing CacheDataSource.", e);
-        }
         source.close();
     }
 
     @Override
     public void reload() { // unused method
-        exec.execute(new Runnable() {
-            @Override
-            public void run() {
         source.reload();
         cachedAuths.invalidateAll();
     }
-        });
-    }
 
     @Override
     public synchronized boolean updateEmail(final PlayerAuth auth) {
@@ -213,14 +197,9 @@ public class CacheDataSource implements DataSource {
 
     @Override
     public synchronized void purgeBanned(final List<String> banned) {
-        exec.execute(new Runnable() {
-            @Override
-            public void run() {
         source.purgeBanned(banned);
         cachedAuths.invalidateAll(banned);
     }
-        });
-    }
 
     @Override
     public DataSourceType getType() {
@@ -234,34 +213,19 @@ public class CacheDataSource implements DataSource {
 
     @Override
     public void setLogged(final String user) {
-        exec.execute(new Runnable() {
-            @Override
-            public void run() {
         source.setLogged(user.toLowerCase());
     }
-        });
-    }
 
     @Override
     public void setUnlogged(final String user) {
-        exec.execute(new Runnable() {
-            @Override
-            public void run() {
         source.setUnlogged(user.toLowerCase());
     }
-        });
-    }
 
     @Override
     public void purgeLogged() {
-        exec.execute(new Runnable() {
-            @Override
-            public void run() {
         source.purgeLogged();
         cachedAuths.invalidateAll();
     }
-        });
-    }
 
     @Override
     public int getAccountsRegistered() {
@@ -269,15 +233,10 @@ public class CacheDataSource implements DataSource {
     }
 
     @Override
-    public void updateName(final String oldOne, final String newOne) {
+    public void updateName(final String oldOne, final String newOne) { // unused method
-        exec.execute(new Runnable() {
-            @Override
-            public void run() {
         source.updateName(oldOne, newOne);
         cachedAuths.invalidate(oldOne);
     }
-        });
-    }
 
     @Override
     public List<PlayerAuth> getAllAuths() {