zhouxy108/hutool
1
0
Fork 0
mirror of https://gitee.com/chinabugotech/hutool.git synced 2025-07-21 15:09:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix code

Browse Source
This commit is contained in:
Looly
2023-04-25 09:09:07 +08:00
parent c8101e6e7f
commit 841845eaaa
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
hutool-socket/src/main/java/org/dromara/hutool/socket/aio/AioServer.java
View File

@@ -17,7 +17,6 @@ import org.dromara.hutool.core.io.IoUtil;
import org.dromara.hutool.core.thread.ThreadFactoryBuilder; import org.dromara.hutool.core.thread.ThreadFactoryBuilder;
import org.dromara.hutool.core.thread.ThreadUtil; import org.dromara.hutool.core.thread.ThreadUtil;
import org.dromara.hutool.log.Log; import org.dromara.hutool.log.Log;
import org.dromara.hutool.log.LogFactory;
import org.dromara.hutool.socket.SocketConfig; import org.dromara.hutool.socket.SocketConfig;
import java.io.Closeable; import java.io.Closeable;
@@ -34,7 +33,7 @@ import java.nio.channels.AsynchronousServerSocketChannel;
* @author looly * @author looly
*/ */
public class AioServer implements Closeable { public class AioServer implements Closeable {
private static final Log log = LogFactory.get(); private static final Log log = Log.get();
private static final AcceptHandler ACCEPT_HANDLER = new AcceptHandler(); private static final AcceptHandler ACCEPT_HANDLER = new AcceptHandler();
private AsynchronousChannelGroup group; private AsynchronousChannelGroup group;
@@ -58,6 +57,7 @@ public class AioServer implements Closeable {
* @param address 地址 * @param address 地址
* @param config {@link SocketConfig} 配置项 * @param config {@link SocketConfig} 配置项
*/ */
@SuppressWarnings("resource")
public AioServer(final InetSocketAddress address, final SocketConfig config) { public AioServer(final InetSocketAddress address, final SocketConfig config) {
this.config = config; this.config = config;
init(address); init(address);
@@ -182,6 +182,7 @@ public class AioServer implements Closeable {
* *
* @param sync 是否阻塞 * @param sync 是否阻塞
*/ */
@SuppressWarnings("resource")
private void doStart(final boolean sync) { private void doStart(final boolean sync) {
log.debug("Aio Server started, waiting for accept."); log.debug("Aio Server started, waiting for accept.");