diff --git a/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java b/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java
index ae07aab..dc68d8a 100644
--- a/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java
+++ b/gameserver/src/main/java/brainwine/gameserver/server/pipeline/Connection.java
@@ -41,22 +41,12 @@ public class Connection extends SimpleChannelInboundHandler<Request> {
             return;
         }
         
-        GameServer.getInstance().queueSynchronousTask(new Runnable() {
-            @Override
-            public void run() {
-                player.onDisconnect();
-            }
-        });
+        GameServer.getInstance().queueSynchronousTask(player::onDisconnect);
     }
     
     @Override
     protected void channelRead0(ChannelHandlerContext ctx, Request request) throws Exception {
-        GameServer.getInstance().queueSynchronousTask(new Runnable() {
-            @Override
-            public void run() {
-                request.process(Connection.this);
-            }
-        });
+        GameServer.getInstance().queueSynchronousTask(() -> request.process(this));
     }
     
     @Override
diff --git a/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java b/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java
index 40c333b..dbaefe0 100644
--- a/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java
+++ b/gameserver/src/main/java/brainwine/gameserver/zone/gen/AsyncZoneGenerator.java
@@ -47,12 +47,7 @@ public class AsyncZoneGenerator extends Thread {
                 Consumer<Zone> callback = task.getCallback();
                 
                 if(callback != null) {
-                    GameServer.getInstance().queueSynchronousTask(new Runnable() {
-                        @Override
-                        public void run() {
-                            callback.accept(generated);
-                        }
-                    });
+                    GameServer.getInstance().queueSynchronousTask(() -> callback.accept(generated));
                 }
             }
         });