Repo-Mirror/AkarinMC
9
0
Fork 0
Code Issues Pull Requests Releases Activity

Improve #77ffdd0 commit code.

Browse Source
This commit is contained in:
Ghost_chu
2019-03-28 21:59:50 +08:00
parent 77ffdd0475
commit 7755f7404f
2 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/main/java/io/akarin/server/core/AkarinAsyncExecutor.java
View File

@@ -9,15 +9,16 @@ import com.google.common.util.concurrent.ThreadFactoryBuilder;
public class AkarinAsyncExecutor {
private static final ExecutorService singleExecutor = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder().setNameFormat("Akarin Single Async Executor Thread - %1$d").build());
private static final ExecutorService asyncExecutor = Executors.newFixedThreadPool(getnThreads(), new ThreadFactoryBuilder().setNameFormat("Akarin Async Executor Thread - %1$d").build());
private static final ExecutorService asyncExecutor = Executors.newFixedThreadPool(getNThreads(), new ThreadFactoryBuilder().setNameFormat("Akarin Async Executor Thread - %1$d").build());
private static int getnThreads(){
int processors = Runtime.getRuntime().availableProcessors();
if(processors > 2){
private static int getNThreads(){
int processors = Runtime.getRuntime().availableProcessors() / 2;
if (processors < 2)
return 2;
if (processors > 8)
return 8;
return processors;
}else {
return 2;
}
}
/**