Класс ScopedValue<T>

public final class ScopedValue<T> extends Object

    private static final ScopedValue<String> NAME = ScopedValue.newInstance();

    ScopedValue.where(NAME, "duke").run(() -> doSomething());

    ScopedValue.where(NAME, "duke1").run(() -> doSomething());

    ScopedValue.where(NAME, "duke2").run(() -> doSomething());

    ScopedValue.where(NAME, "duchess").run(() -> doMore());

    private static final ScopedValue<String> NAME = ScopedValue.newInstance();

    ScopedValue.where(NAME, "duke").run(() -> {
        try (var scope = StructuredTaskScope.open()) {

             scope.fork(() -> childTask1());
             scope.fork(() -> childTask2());
             scope.fork(() -> childTask3());

             scope.join();

             ..
         }
    });

Примечание к API:

В случаях, когда требуется «односторонняя передача» данных без использования параметров методов, следует предпочесть ScopedValue вместо ThreadLocal. Хотя ThreadLocal можно использовать для передачи данных методу без параметров методов, у него есть ряд недостатков:

1. ThreadLocal не препятствует удалённому вызываемому коду установить новое значение.
2. Срок жизни ThreadLocal не ограничен, поэтому оно продолжает хранить значение после завершения метода, если его явно не удалить.
3. Наследование требует значительных затрат: карту локальных переменных потока и их значений необходимо копировать при создании каждого дочернего потока.

Примечание по реализации:

Ограниченные значения предназначены для использования в относительно небольшом количестве. Метод get() сначала выполняет поиск по охватывающим областям, чтобы найти внутреннюю привязку ограниченного значения. Затем результат поиска кэшируется в небольшом кэше, локальном для потока. Последующие вызовы get() для этого ограниченного значения почти всегда будут очень быстрыми. Однако если программа циклически использует множество ограниченных значений, частота попаданий в кэш будет низкой, а производительность — неудовлетворительной. Такая конструкция позволяет очень быстро наследовать ограниченные значения потокам StructuredTaskScope^{ПРЕДВАРИТЕЛЬНАЯ ВЕРСИЯ}: по сути, достаточно скопировать указатель; для выхода из привязки ограниченного значения также требуется лишь обновить указатель.

Поскольку кэш ограниченных значений для каждого потока невелик, клиентам следует сводить к минимуму количество используемых привязанных ограниченных значений. Например, если таким способом необходимо передать несколько значений, имеет смысл создать класс-запись для их хранения, а затем привязать одно ScopedValue к экземпляру этой записи.

В этой версии эталонная реализация предоставляет системные свойства для настройки производительности ограниченных значений.

Системное свойство java.lang.ScopedValue.cacheSize управляет размером кэша ограниченных значений (для каждого потока). Этот кэш имеет решающее значение для производительности ограниченных значений. Если он слишком мал, библиотеке времени выполнения придётся многократно выполнять поиск для каждого вызова get(). Если он слишком велик, память будет расходоваться без необходимости. По умолчанию кэш ограниченных значений содержит 16 записей. Его размер можно изменять в диапазоне от 2 до 16 записей. Значение ScopedValue.cacheSize должно быть целой степенью числа 2.

Например, можно использовать -Djava.lang.ScopedValue.cacheSize=8.

Другое системное свойство — jdk.preserveScopedValueCache. Это свойство определяет, сохраняется ли кэш ограниченных значений для каждого потока, когда виртуальный поток блокируется. По умолчанию для этого свойства установлено значение true, то есть каждый виртуальный поток сохраняет свой кэш ограниченных значений при блокировке. Как и в случае с ScopedValue.cacheSize, здесь приходится выбирать между экономией памяти и скоростью: если множество виртуальных потоков большую часть времени заблокировано, установка для этого свойства значения false может существенно сократить расход памяти, но кэш ограниченных значений каждого виртуального потока придётся заново создавать после блокирующей операции.

Начиная с версии:

25