Класс ScopedValue

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 = new StructuredTaskScope<String>()) {

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

             scope.join();

             ..
         }
    });

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

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

1. Устанавливать новое значение не блокируется кодом в удалённом вызывающем объекте.
2. ThreadLocal имеет неограниченный срок жизни и, таким образом, продолжает иметь значение после завершения метода, если его не удалить явно с помощью удаления.
3. Наследование с использованием наследования является ресурсоёмким – при создании каждого дочернего потока необходимо копировать карту нитей-локалей к значениям.

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

Значения области действия предназначены для использования в небольшом количестве. get() изначально выполняет поиск по охватывающим областям, чтобы найти самое внутреннее связывание значения области действия. Затем он кэширует результат поиска в небольшом кэше нитей. Последующие вызовы get() для этого значения области действия практически всегда будут очень быстрыми. Однако, если программа использует множество значений области действия циклически, коэффициент попадания в кэш будет низким, и производительность будет плохой. Эта конструкция позволяет наследованию значений области действия через StructuredTaskScope^{ПРОСМОТР} потоков быть очень быстрым: по сути, не более чем копирования указателя, и отключение связывания значения области действия также требует немного больше, чем обновление указателя.

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

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

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

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

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

С тех пор как:

21