¿Hay variables locales de grupos de subprocesos en Java?

Question

Estoy buscando una clase similar a ThreadLocal que funcione en grupos de hilos en lugar de hilos.

Si no existe tal clase (en alguna biblioteca de código abierto) ¿cómo la implementaría? ¿Alguna idea mejor que tener grupos de subprocesos en WeakHashMap?

Estoy implementando un marco de depuración optimizable en tiempo de ejecución con varios parámetros en contextos globales, por subproceso y por grupo de subprocesos. Como un ejemplo muy simple, puede tener una declaración de informes:

debug.log(category, message); 

y especificar que la entrada de registro con esa categoría específica se mostrará sólo cuando es llamado por un hilo en el grupo de hilos están sirviendo peticiones de red.

Answer 1

Guardaría un soporte de valor en un subproceso local e lo inicializaría en el mismo soporte de valor para todos los subprocesos del mismo grupo.

public class ThreadGroupLocal<T> extends ThreadLocal<ValueHolder> { 
    private static class ValueHolder { 
     public Object value; 
    } 
    // Weak & Concurrent would be even the better, but Java API wont offer that :(
    private static ConcurrentMap<ThreadGroup, ValueHolder> map = new ConcurrentHashMap<ThreadGroup, ValueHolder>; 
    private static ValueHolder valueHolderForThread(Thread t) { 
     map.putIfAbsent(t.getThreadGroup(), new ValueHolder()); 
     return map.get(t.getThreadGroup()); 
    } 
    @Override 
    protected ValueHolder initialValue() { 
     return valueHolderForThread(Thread.currentThread()); 
    } 
    public T getValue() { (T) get().value; } 
    public void setValue(T value) { get().value = value; } 
} 

y luego usar

ThreadGroupLocal<String> groupLocal = new ThreadGroupLocal<String>(); 
groupLocal.setValue("foo"); 
//... 
String foo = groupLocal.getValue(); 

Eso no (esperar para la inicialización) realizan exactamente igual que una secuencia de procesamiento local.

Answer 2

La última vez que miré la implementación (bueno hace unos años) Thread Locals se implementaron como una simple tabla hash indexada por el id. De subproceso. Nada lujoso y lejos de la eficiencia de C++.

Puede hacer lo mismo y usar el objeto del grupo de hilos como una clave para su propia tabla de hash de locales del grupo de hilos.

Answer 3

ThreadGroup se usa raramente, por lo que no hay soporte de plataforma.

Utilizando [Weak/Identity/Concurrent] HashMap<ThreadGroup,T> se trata sólo de trabajo, si no es muy rápido. Realmente quieres que el mapa sea todo débil, identidad y concurrente, pero con la biblioteca Java solo puedes elegir uno, actualmente.

Para mejorar el rendimiento, tenga en cuenta que Thread s no cambian ThreadGroup. Por lo tanto, guarde en caché el valor con ThreadLocal (anule initialValue). ThreadLocal tiene un buen rendimiento (un par de docenas de ciclos por get).