Upstream/BungeeCord
1
0
Fork 0
mirror of https://github.com/SpigotMC/BungeeCord.git synced 2024-11-28 05:05:21 +01:00
Code Issues Projects Releases Wiki Activity

Work around JDK stupidity with regards to thread count

Browse Source
This commit is contained in:
md_5 2013-03-21 16:25:05 +11:00
parent a59e0f0b6b
commit 5e31b158e9
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
proxy/src/main/java/net/md_5/bungee/BungeeCord.java
View File

@ -76,7 +76,8 @@ public class BungeeCord extends ProxyServer
/** /**
* Thread pools. * Thread pools.
*/ */
public final ScheduledExecutorService executors = new ScheduledThreadPoolExecutor( 8, new ThreadFactoryBuilder().setNameFormat( "Bungee Pool Thread #%1$d" ).build() ); public final ScheduledThreadPoolExecutor executors = new ScheduledThreadPoolExecutor( Integer.MAX_VALUE,
new ThreadFactoryBuilder().setNameFormat( "Bungee Pool Thread #%1$d" ).build() );
public final MultithreadEventLoopGroup eventLoops = new NioEventLoopGroup( 0, new ThreadFactoryBuilder().setNameFormat( "Netty IO Thread #%1$d" ).build() ); public final MultithreadEventLoopGroup eventLoops = new NioEventLoopGroup( 0, new ThreadFactoryBuilder().setNameFormat( "Netty IO Thread #%1$d" ).build() );
/** /**
* locations.yml save thread. * locations.yml save thread.
@ -186,6 +187,9 @@ public class BungeeCord extends ProxyServer
@Override @Override
public void start() throws Exception public void start() throws Exception
{ {
executors.setKeepAliveTime( 60, TimeUnit.SECONDS );
executors.allowCoreThreadTimeOut( true );
pluginsFolder.mkdir(); pluginsFolder.mkdir();
pluginManager.loadPlugins( pluginsFolder ); pluginManager.loadPlugins( pluginsFolder );
config.load(); config.load();
@ -249,7 +253,7 @@ public class BungeeCord extends ProxyServer
{ {
this.isRunning = false; this.isRunning = false;
httpClient.closeAsynchronously(); // TODO: Fix httpClient.close();
executors.shutdown(); executors.shutdown();
stopListeners(); stopListeners();