mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-05-23 10:25:33 +00:00
feat[executor]:add method to get executor based on hash
This commit is contained in:
@@ -29,11 +29,13 @@ import java.util.ArrayList;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.CompletableFuture;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
import java.util.concurrent.Executors;
|
||||
import java.util.concurrent.ThreadFactory;
|
||||
import java.util.concurrent.atomic.AtomicInteger;
|
||||
import java.util.function.Consumer;
|
||||
import java.util.function.Supplier;
|
||||
|
||||
/**
|
||||
* @author godotg
|
||||
@@ -151,6 +153,10 @@ public abstract class EventBus {
|
||||
receiverMap.computeIfAbsent(eventType, it -> new ArrayList<>(1)).add(receiver);
|
||||
}
|
||||
|
||||
public static ExecutorService getExecutor(int executorHash){
|
||||
return executors[Math.abs(executorHash % EXECUTORS_SIZE)];
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
|
||||
@@ -123,4 +123,8 @@ public final class TaskBus {
|
||||
return executor;
|
||||
}
|
||||
|
||||
public static ExecutorService getExecutor(int hash){
|
||||
return executors[calTaskExecutorIndex(hash)];
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user