add lombok code

Author: Peng Hu

src/main/java/info/xiaomo/gengine/network/netty/NettyTcpClient.java

@@ -102,7 +102,7 @@ private synchronized void connect() {
 
 			for (int i = channels.size(); i < nettyClientConfig.getMaxConnectCount(); i++) {
 				ChannelFuture channelFuture = bootstrap.connect(nettyClientConfig.getIp(), nettyClientConfig.getPort());
-				channelFuture.awaitUninterruptibly(10000);    //最多等待10秒，如果服务器一直未开启情况下，房子阻塞当前线程
+				channelFuture.awaitUninterruptibly(10000);    //最多等待10秒，如果服务器一直未开启情况下，防止阻塞当前线程
 				channels.add(channelFuture.channel());
 				channelFuture.addListener(future -> {
 					if (future.isSuccess()) {

src/main/java/info/xiaomo/gengine/thread/ThreadPoolExecutorConfig.java

@@ -1,10 +1,12 @@
 package info.xiaomo.gengine.thread;
 
+import lombok.Data;
+import org.simpleframework.xml.Element;
+import org.simpleframework.xml.Root;
+
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
-import org.simpleframework.xml.Element;
-import org.simpleframework.xml.Root;
 
 /**
  * 线程池配置
@@ -13,86 +15,36 @@
  * 2017-03-30
  */
 @Root
+@Data
 public class ThreadPoolExecutorConfig {
 
-	// 线程池名称
-	@Element(required = false)
-	private String name;
-
-	// 核心线程池值
-	@Element(required = true)
-	private int corePoolSize = 20;
-
-	// 线程池最大值
-	@Element(required = true)
-	private int maxPoolSize = 200;
-
-	// 线程池保持活跃时间(秒)
-	@Element(required = true)
-	private long keepAliveTime = 30L;
-
-	// 心跳间隔（大于0开启定时监测线程）
-	@Element(required = false)
-	private int heart;
-
-	// 缓存命令数
-	@Element(required = false)
-	private int commandSize = 100000;
-
-	public ThreadPoolExecutor newThreadPoolExecutor() throws RuntimeException {
-		return new ThreadPoolExecutor(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS,
-				new LinkedBlockingQueue<>(commandSize), new IoThreadFactory());
-	}
-
-	public String getName() {
-		return name;
-	}
-
-	public void setName(String name) {
-		this.name = name;
-	}
-
-	public int getCorePoolSize() {
-		return corePoolSize;
-	}
-
-	@Deprecated
-	public void setCorePoolSize(int corePoolSize) {
-		this.corePoolSize = corePoolSize;
-	}
-
-	public int getMaxPoolSize() {
-		return maxPoolSize;
-	}
-
-	@Deprecated
-	public void setMaxPoolSize(int maxPoolSize) {
-		this.maxPoolSize = maxPoolSize;
-	}
+    // 线程池名称
+    @Element(required = false)
+    private String name;
 
-	public long getKeepAliveTime() {
-		return keepAliveTime;
-	}
+    // 核心线程池值
+    @Element()
+    private int corePoolSize = 20;
 
-	@Deprecated
-	public void setKeepAliveTime(long keepAliveTime) {
-		this.keepAliveTime = keepAliveTime;
-	}
+    // 线程池最大值
+    @Element()
+    private int maxPoolSize = 200;
 
-	public int getHeart() {
-		return heart;
-	}
+    // 线程池保持活跃时间(秒)
+    @Element()
+    private long keepAliveTime = 30L;
 
-	public void setHeart(int heart) {
-		this.heart = heart;
-	}
+    // 心跳间隔（大于0开启定时监测线程）
+    @Element(required = false)
+    private int heart;
 
-	public int getCommandSize() {
-		return commandSize < 10000 ? 10000 : commandSize;
-	}
+    // 缓存命令数
+    @Element(required = false)
+    private int commandSize = 100000;
 
-	public void setCommandSize(int commandSize) {
-		this.commandSize = commandSize;
-	}
+    public ThreadPoolExecutor newThreadPoolExecutor() throws RuntimeException {
+        return new ThreadPoolExecutor(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS,
+                new LinkedBlockingQueue<>(commandSize), new IoThreadFactory());
+    }
 
 }