Cleanup o/e/c/u/c/EsExecutors.java
This commit removes two unused imports and applies a few other formatting cleanups to EsExecutors.java.
This commit is contained in:
parent
5608fa7ac1
commit
d032de2df2
|
@ -25,18 +25,13 @@ import org.elasticsearch.common.settings.Settings;
|
||||||
|
|
||||||
import java.util.Arrays;
|
import java.util.Arrays;
|
||||||
import java.util.concurrent.BlockingQueue;
|
import java.util.concurrent.BlockingQueue;
|
||||||
import java.util.concurrent.LinkedBlockingQueue;
|
|
||||||
import java.util.concurrent.LinkedTransferQueue;
|
import java.util.concurrent.LinkedTransferQueue;
|
||||||
import java.util.concurrent.SynchronousQueue;
|
|
||||||
import java.util.concurrent.ThreadFactory;
|
import java.util.concurrent.ThreadFactory;
|
||||||
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.ThreadPoolExecutor;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
import java.util.stream.Collectors;
|
import java.util.stream.Collectors;
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class EsExecutors {
|
public class EsExecutors {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -110,6 +105,7 @@ public class EsExecutors {
|
||||||
}
|
}
|
||||||
|
|
||||||
static class EsThreadFactory implements ThreadFactory {
|
static class EsThreadFactory implements ThreadFactory {
|
||||||
|
|
||||||
final ThreadGroup group;
|
final ThreadGroup group;
|
||||||
final AtomicInteger threadNumber = new AtomicInteger(1);
|
final AtomicInteger threadNumber = new AtomicInteger(1);
|
||||||
final String namePrefix;
|
final String namePrefix;
|
||||||
|
@ -129,6 +125,7 @@ public class EsExecutors {
|
||||||
t.setDaemon(true);
|
t.setDaemon(true);
|
||||||
return t;
|
return t;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -137,7 +134,6 @@ public class EsExecutors {
|
||||||
private EsExecutors() {
|
private EsExecutors() {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
static class ExecutorScalingQueue<E> extends LinkedTransferQueue<E> {
|
static class ExecutorScalingQueue<E> extends LinkedTransferQueue<E> {
|
||||||
|
|
||||||
ThreadPoolExecutor executor;
|
ThreadPoolExecutor executor;
|
||||||
|
@ -166,6 +162,7 @@ public class EsExecutors {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -188,4 +185,5 @@ public class EsExecutors {
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue