Se o programa possui várias interações diferentes com threads, faz sentido centralizar e encapsular esta funcionalidade em uma classe especializada.
Sobre o nome, eu evitaria qualquer coisa com nome de "global" e, neste caso, expondo detalhes de implementação.
A priori, eu modelaria esta classe primeiramente definindo interfaces para o gerenciador que executa as funções do programa e para os comandos. Exemplo:
interface Comando {
void executar();
}
interface GerenciadorExecucao {
void executar(Comando c);
}
Note que as interfaces não dizem como os comandos serão executados. Tal detalhe será gerenciado pela implementação e as outras classes não tem nada a ver com isto, para elas isto é transparente, elas apenas esperam que o comando seja executado.
Quanto à implementação, eu criaria uma classe chamada GerenciadorExecucaoAssincrono
contendo um thread pool cujas threads consumem os comandos de uma fila sincronizada como LinkedBlockingQueue
. Exemplo;
class GerenciadorExecucaoAssincrono implements GerenciadorExecucao {
private final int maximumPoolSize = 4;
private final ThreadFactory threadFactory = new ThreadFactoryBuilder().setNameFormat("Orders-%d").setDaemon(true).build();
private final ExecutorService executorService = Executors.newFixedThreadPool(maximumPoolSize, threadFactory);
private final LinkedBlockingQueue<Comando> queue = new LinkedBlockingQueue<>()
public GerenciadorExecucaoAssincrono() {
//thread que fica em loop infinito consumindo os comandos da fila
executorService.submit(() -> {
while(true) {
Comando c = queue.take(); //espera por um comando na fila
c.executar();
}
});
}
public void executar(Comando c) {
//adiciona o comando à fila, desbloqueando a thread acima
queue.put(c);
}
}
Agora você pode criar qualquer implementação de comando em outras classes. Dessa forma, cada funcionalidade do seu sistema pode usar a nova API de execução assíncrona e de forma desacoplada.
No exemplo acima, eu criei uma única thread consumindo os comandos, então o resultado é que os comandos são executados na mesma ordem em que são adicionados à fila.
NO entanto, você pode ter várias threads e executá-los em paralelo, basta submeter várias vezes o mesmo Runnable
que eu coloquei no lambda acima. O problema disso é que os comandos executados ao mesmo tempo poderiam ter um efeito indesejado, já que você tem um equipamento físico e possíveis limitações. Cabe a você analisar isto e pensar na melhor estratégia.