移除默认tiny=true系统变量
This commit is contained in:
@@ -131,7 +131,6 @@
|
|||||||
System.setProperty("redkale.net.transport.poolmaxconns", "100");
|
System.setProperty("redkale.net.transport.poolmaxconns", "100");
|
||||||
System.setProperty("redkale.net.transport.pinginterval", "30");
|
System.setProperty("redkale.net.transport.pinginterval", "30");
|
||||||
System.setProperty("redkale.net.transport.checkinterval", "30");
|
System.setProperty("redkale.net.transport.checkinterval", "30");
|
||||||
System.setProperty("redkale.convert.tiny", "true");
|
|
||||||
System.setProperty("redkale.convert.pool.size", "128");
|
System.setProperty("redkale.convert.pool.size", "128");
|
||||||
System.setProperty("redkale.convert.writer.buffer.defsize", "4096");
|
System.setProperty("redkale.convert.writer.buffer.defsize", "4096");
|
||||||
System.setProperty("redkale.trace.enable", "false");
|
System.setProperty("redkale.trace.enable", "false");
|
||||||
|
|||||||
@@ -310,9 +310,6 @@ public final class Application {
|
|||||||
if (System.getProperty("redkale.net.transport.checkinterval") == null) {
|
if (System.getProperty("redkale.net.transport.checkinterval") == null) {
|
||||||
System.setProperty("redkale.net.transport.checkinterval", "30");
|
System.setProperty("redkale.net.transport.checkinterval", "30");
|
||||||
}
|
}
|
||||||
if (System.getProperty("redkale.convert.tiny") == null) {
|
|
||||||
System.setProperty("redkale.convert.tiny", "true");
|
|
||||||
}
|
|
||||||
if (System.getProperty("redkale.convert.pool.size") == null) {
|
if (System.getProperty("redkale.convert.pool.size") == null) {
|
||||||
System.setProperty("redkale.convert.pool.size", "128");
|
System.setProperty("redkale.convert.pool.size", "128");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -117,8 +117,8 @@ public class CacheClusterAgent extends ClusterAgent implements Resourcable {
|
|||||||
public void start() {
|
public void start() {
|
||||||
if (this.scheduler == null) {
|
if (this.scheduler == null) {
|
||||||
AtomicInteger counter = new AtomicInteger();
|
AtomicInteger counter = new AtomicInteger();
|
||||||
this.scheduler = new ScheduledThreadPoolExecutor(4, (Runnable r) -> {
|
this.scheduler = new ScheduledThreadPoolExecutor(1, (Runnable r) -> {
|
||||||
final Thread t = new Thread(r, "Redkale-" + CacheClusterAgent.class.getSimpleName() + "-Task-Thread-" + counter.incrementAndGet());
|
final Thread t = new Thread(r, "Redkale-" + CacheClusterAgent.class.getSimpleName() + "-Check-Thread-" + counter.incrementAndGet());
|
||||||
t.setDaemon(true);
|
t.setDaemon(true);
|
||||||
return t;
|
return t;
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user