eclipse-sailing-analytics/sailing-analytics
1
0
Fork 0
mirror of https://github.com/eclipse-sailing-analytics/sailing-analytics.git synced 2026-09-22 13:45:42 +00:00
Code Activity

Bug 5214: replacing standard thread pool executors by own thread pool

Browse Source 
executors
This commit is contained in:
Thomas Wiese
2020-08-07 16:05:40 +02:00
parent 22c6f905ff
commit f3b8534c05
3 changed files with 21 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/com.sap.sse.operationaltransformation/src/com/sap/sse/operationaltransformation/PeerImpl.java
+16 -11
View File
@@ -4,11 +4,10 @@ import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.logging.Level;
import java.util.logging.Logger;
import com.sap.sse.util.impl.ThreadFactoryWithPriority;
import com.sap.sse.util.ThreadPoolUtil;
/**
@@ -63,10 +62,11 @@ public class PeerImpl<O extends Operation<S>, S> implements Peer<O, S> {
private final ExecutorService merger;
public PeerImpl(Transformer<S, O> transformer, S initialState, Role role) {
this.transformer = transformer;
currentState = initialState;
this.role = role;
this.merger = Executors.newSingleThreadExecutor(new ThreadFactoryWithPriority(Thread.NORM_PRIORITY, /* daemon */ true));
this.transformer = transformer;
currentState = initialState;
this.role = role;
this.merger = createMerger();
}
public PeerImpl(String name, Transformer<S, O> transformer, S initialState, Role role) {
@@ -80,12 +80,12 @@ public class PeerImpl<O extends Operation<S>, S> implements Peer<O, S> {
* the server.
*/
public PeerImpl(Transformer<S, O> transformer, Peer<O, S> server) {
this.transformer = transformer;
S initialState = server.addPeer(this);
this.transformer = transformer;
S initialState = server.addPeer(this);
currentState = initialState;
this.role = Role.CLIENT;
this.merger = Executors.newSingleThreadExecutor(new ThreadFactoryWithPriority(Thread.NORM_PRIORITY, /* daemon */ true));
addPeer(server);
this.role = Role.CLIENT;
this.merger = createMerger();
addPeer(server);
}
/**
@@ -103,6 +103,11 @@ public class PeerImpl<O extends Operation<S>, S> implements Peer<O, S> {
merger.shutdown();
}
private ExecutorService createMerger() {
return ThreadPoolUtil.INSTANCE.createBackgroundTaskThreadPoolExecutor(1,
this.getClass().getName() + " " + name);
}
private Transformer<S, O> getTransformer() {
return transformer;
}