Czy w języku Java istnieje wieloznaczna pula wątków z możliwością indeksowania?

Question

Czy istnieje klasa Java takie, że:

1. wykonywalne zadania mogą być dodawane za pomocą identyfikatora, w których zagwarantowane wszystkie zadania z tym samym identyfikatorem, aby nie biec równolegle
2. Liczba wątków może być ograniczona do stała kwota:

Naiwne rozwiązanie mapy łatwo by się rozwiązało (1), ale byłoby trudno zarządzać (2). Podobnie, wszystkie klasy łączenia wątków, które znam, będą pobierane z pojedynczej kolejki, co oznacza, że ​​(1) nie jest gwarantowane.

Rozwiązania z udziałem bibliotek zewnętrznych są mile widziane.

Answer 1

Jeśli nie znajdziesz czegoś, co robi to po wyjęciu z pudełka, nie powinno być ciężko toczyć własne. Jedną rzeczą, jaką można zrobić, to owinąć każde zadanie w prosty klasy, który czyta w kolejce za unikalny identyfikator, np .:

public static class SerialCaller<T> implements Callable<T> { 
    private final BlockingQueue<Caller<T>> delegates; 

    public SerialCaller(BLockingQueue<Caller<T>> delegates) { 
     this.delegates = delegates; 
    } 

    public T call() throws Exception { 
     return delegates.take().call(); 
    } 
} 

To powinno być łatwe do utrzymania mapę identyfikatorów kolejek składania zadań. To spełnia warunek (1), a następnie możesz szukać prostych rozwiązań warunku (2), takich jak Executors. newFixedThreadPool

Answer 2

Myślę, że najprostszym rozwiązaniem jest posiadanie osobnej kolejki dla każdego indeksu i osobnego executora (z jeden wątek) dla każdej kolejki.

Jedyne, co można osiągnąć przy bardziej złożonym rozwiązaniu, to użyć mniejszej liczby wątków, ale jeśli liczba indeksów jest mała i ograniczona, prawdopodobnie nie jest to warte wysiłku.

Answer 3

Dla każdego identyfikatora potrzebny jest SerialExecutor, opisany w dokumentacji java.util.concurrent.Executor. Wszyscy seryjni wykonawcy delegują pracę do ThreadPoolExecutor z podanym corePoolSize.

Opcjonalną wersję SerialExecutor można znaleźć pod adresem my code samples.