1 files changed, 2 insertions, 4 deletions
diff --git a/src/main/java/io/trygvis/async/JdbcAsyncService.java b/src/main/java/io/trygvis/async/JdbcAsyncService.java
index fd4b38b..57ab5c6 100644
--- a/src/main/java/io/trygvis/async/JdbcAsyncService.java
+++ b/src/main/java/io/trygvis/async/JdbcAsyncService.java
@@ -71,12 +71,10 @@ public class JdbcAsyncService {
     }
 
     public Task update(Connection c, Task ref) throws SQLException {
-        TaskDao taskDao = queueSystem.createTaskDao(c);
-
-        return taskDao.findById(ref.id());
+        return queueSystem.createTaskDao(c).findById(ref.id());
     }
 
-    private QueueController getQueueThread(String name) {
+    private synchronized QueueController getQueueThread(String name) {
         QueueController queueController = queues.get(name);
 
         if (queueController == null) {