尝试修改充值bug
parent
d67a15b22c
commit
f22e88f327
|
@ -157,4 +157,7 @@ public class ThreadManager implements IManager {
|
|||
executor.execute(task);
|
||||
}
|
||||
|
||||
public static ThreadPoolExecutor getExecutor() {
|
||||
return executor;
|
||||
}
|
||||
}
|
||||
|
|
|
@ -4,6 +4,7 @@ import com.google.gson.Gson;
|
|||
import com.ljsd.CoreService;
|
||||
import com.ljsd.GameApplication;
|
||||
import com.ljsd.jieling.config.json.CoreSettings;
|
||||
import com.ljsd.jieling.thread.ThreadManager;
|
||||
import com.ljsd.jieling.thrift.idl.RPCRequestIFace;
|
||||
import com.ljsd.jieling.util.ConfigurableApplicationContextManager;
|
||||
import org.apache.thrift.TProcessor;
|
||||
|
@ -43,6 +44,7 @@ public class RPCServerTask extends Thread{
|
|||
TBinaryProtocol.Factory proFactory = new TBinaryProtocol.Factory(true, true);
|
||||
trArgs.protocolFactory(proFactory);
|
||||
trArgs.maxWorkerThreads(16);
|
||||
trArgs.executorService(ThreadManager.getExecutor());
|
||||
LOGGER.info("run->RPC services is starting.");
|
||||
final TServer server = new TThreadPoolServer(trArgs);
|
||||
while (true) {
|
||||
|
|
Loading…
Reference in New Issue