Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2025-01-23 00:21:26 +01:00
Code Issues Projects Releases Wiki Activity

Close the main selector

Browse Source
This commit is contained in:
TheMode 2021-08-04 05:19:11 +02:00
parent 8895e49a52
commit 0d91f9efc6
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/net/minestom/server/network/socket/Server.java
View File

@ -24,6 +24,7 @@ public class Server {
private volatile boolean stop; private volatile boolean stop;
private final Selector selector = Selector.open();
private final List<Worker> workers = new ArrayList<>(WORKER_COUNT); private final List<Worker> workers = new ArrayList<>(WORKER_COUNT);
private int index; private int index;
@ -39,7 +40,6 @@ public class Server {
} }
public void start(SocketAddress address) throws IOException { public void start(SocketAddress address) throws IOException {
Selector selector = Selector.open();
this.serverSocket = ServerSocketChannel.open(); this.serverSocket = ServerSocketChannel.open();
serverSocket.bind(address); serverSocket.bind(address);
serverSocket.configureBlocking(false); serverSocket.configureBlocking(false);
@ -65,6 +65,7 @@ public class Server {
public void stop() { public void stop() {
this.stop = true; this.stop = true;
this.selector.wakeup();
this.workers.forEach(worker -> worker.selector.wakeup()); this.workers.forEach(worker -> worker.selector.wakeup());
} }