线程池使用实例

Posted 2020-08-21

线程池：

package com.mainserver;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.config.ServerConfig;

/**
* 业务线程池
* */
public class ThreadBusiness {

private static final Logger LOGGER = LoggerFactory.getLogger(ThreadBusiness.class);

private final ExecutorService executorService;

private static ThreadBusiness INSTANCE = new ThreadBusiness(ServerConfig.getInstance().getHandleThreadNumber());

public static ThreadBusiness getInstance() {
return INSTANCE;
}

private ThreadBusiness(int threadNumber) {
executorService = Executors.newFixedThreadPool(threadNumber);
}

/**
* 执行线程
* */
public void execute(Runnable runnable) {
if (null == runnable) {
return ;
}

executorService.execute(runnable);
}

/**
* 关闭线程池
*/
public void shutdown() {
try {
executorService.shutdown();
while (executorService.awaitTermination(1, TimeUnit.SECONDS)) {
LOGGER.info("server executor stop");
break;
}
} catch (InterruptedException e) {
LOGGER.error("server awaitTermination exception: {}", e);
}
}

}

 

 

 

 

 

 

 

执行线程：

public class ServerNetHandler extends SimpleChannelInboundHandler<ReqPacket> {

@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
System.out.println("get new connect..");

writeData(ctx.channel());
}

@Override
protected void channelRead0(ChannelHandlerContext ctx, ReqPacket reqPacket) throws Exception {
if (!(reqPacket instanceof ReqPacket)) {
if (ServerConfig.getInstance().ismScreepPrint()) {
System.out.println("it isnt my type");
}
return;
}

RequestHandler handler = new RequestHandler(reqPacket);
ThreadBusiness.getInstance().execute(handler);
}
}

 

 

 

线程业务：

public class RequestHandler implements Runnable {

private static final Logger log = LoggerFactory.getLogger(RequestHandler.class);

private ReqPacket req;

public RequestHandler(ReqPacket reqPacket) {
this.req = reqPacket;
}

@Override
public void run() {
switch (req.header.cmd) {
case eCommand.LOGIN_SERVER_LIST_VALUE:
// 获取登录服列表
writeLoginList(req);
break;
case eCommand.SYS_ADDANDUPDATE_SERVERLIST_VALUE:
// 增加和更新登录服务器列表
sysAddAndUpdateServerList(req);
break;

default:
break;
}
}