MiniDay/hamster-ball
1
0
Fork 0
Code Issues Pull Requests Actions Releases 9 Activity

perf: 优化性能

Browse Source
This commit is contained in:
叁只仓鼠
2023-06-01 09:04:44 +08:00
parent 503ba16c6e
commit 0ca763ebdb
9 changed files with 21 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hamster-ball-common/build.gradle
View File

@@ -3,9 +3,10 @@ setArchivesBaseName("HamsterBall-Common")
dependencies {
// https://mvnrepository.com/artifact/com.google.code.gson/gson
//noinspection GradlePackageUpdate
//noinspection VulnerableLibrariesLocal
compileOnly 'com.google.code.gson:gson:2.8.0'
// https://mvnrepository.com/artifact/io.netty/netty-all
compileOnly 'io.netty:netty-all:4.1.82.Final'
compileOnly 'io.netty:netty-all:4.1.86.Final'
compileOnly "cn.hamster3.mc.plugin.core:common:${hamster_core_version}"

3
hamster-ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/connector/BallChannelInitializer.java
View File

@@ -13,9 +13,6 @@ import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeUnit;
public class BallChannelInitializer extends ChannelInitializer<SocketChannel> {
public BallChannelInitializer() {
}
@Override
protected void initChannel(@NotNull SocketChannel channel) {
channel.pipeline()

11
hamster-ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/utils/OS.java
View File

@@ -1,5 +1,6 @@
package cn.hamster3.mc.plugin.ball.common.utils;
import cn.hamster3.mc.plugin.core.common.thread.NamedThreadFactory;
import io.netty.channel.Channel;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.ServerChannel;
@@ -14,12 +15,16 @@ import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import org.jetbrains.annotations.NotNull;
import java.util.concurrent.ThreadFactory;
public enum OS {
WINDOWS,
LINUX,
MACOS,
OTHER;
private static final ThreadFactory THREAD_FACTORY = new NamedThreadFactory("HamsterBall-IO");
@NotNull
public static OS getCurrentOS() {
String s = System.getProperties().get("os.name").toString().toLowerCase();
@@ -50,11 +55,11 @@ public enum OS {
public EventLoopGroup getEventLoopGroup(int nThread) {
switch (this) {
case LINUX:
return new EpollEventLoopGroup(nThread);
return new EpollEventLoopGroup(nThread, THREAD_FACTORY);
case MACOS:
return new KQueueEventLoopGroup(nThread);
return new KQueueEventLoopGroup(nThread, THREAD_FACTORY);
default:
return new NioEventLoopGroup(nThread);
return new NioEventLoopGroup(nThread, THREAD_FACTORY);
}
}