Класс RecordingStream

Следующий пример показывает, как создать поток записи, использующий предопределённую конфигурацию.

 var c = Configuration.getConfiguration("default");
 try (var rs = new RecordingStream(c)) {
   rs.onEvent(System.out::println);
   rs.start();
 }
 

Если несколько событий имеют одинаковое имя (например, один и тот же класс загружен в разных загрузчиках классов), тогда все события, соответствующие имени, включаются. Чтобы включить определённый класс, используйте метод enable(Class) или представление типа события ID.

Следующий пример записывает 20 секунд, используя конфигурацию "default", а затем изменяет настройки на конфигурацию "profile".

 Configuration defaultConfiguration = Configuration.getConfiguration("default");
 Configuration profileConfiguration = Configuration.getConfiguration("profile");
 try (var rs = new RecordingStream(defaultConfiguration)) {
    rs.onEvent(System.out::println);
    rs.startAsync();
    Thread.sleep(20_000);
    rs.setSettings(profileConfiguration.getSettings());
    Thread.sleep(20_000);
 }
 

Если несколько событий с одинаковым именем (например, один и тот же класс загружен в разных загрузчиках классов), все события, соответствующие имени, отключаются. Чтобы отключить конкретный класс, используйте метод disable(Class) или представление типа события ID.

Для управления количеством данных записи, хранящихся на диске, можно указать максимальное время хранения данных. Данные, хранящиеся на диске и старше указанного времени, удаляются виртуальной машиной Java (JVM).

Если не заданы ни максимальный предел, ни максимальный срок, размер записи может неограниченно расти, если события включены

Для управления количеством данных записи, хранящихся на диске, можно указать максимальный объём данных для хранения. Когда максимальный предел превышен, виртуальная машина Java (JVM) удаляет самую старую часть, чтобы освободить место для более новой.

Если не заданы ни максимальный предел, ни максимальный срок, размер записи может неограниченно расти.

Размер измеряется в байтах.

Если повторное использование установлено в true, действие не должно хранить ссылку на объект события после завершения действия.

Начальное время должно быть установлено до запуска потока.

Конечное время должно быть установлено до запуска потока.

В конечное время поток закрывается.

Если поток уже закрыт, действие будет выполнено немедленно в текущей нити.

Если действие не зарегистрировано, трассировка стека исключений выводится в стандартный поток ошибок.

Регистрация действия переопределяет поведение по умолчанию. Если зарегистрировано несколько действий, они выполняются в порядке регистрации.

Если этот метод сам вызывает исключение, поведение не определено.

Если действие зарегистрировано несколько раз, все экземпляры удаляются.

Действия выполняются в текущей нити.

Чтобы остановить поток, используйте метод EventStream.close().

Действия выполняются в отдельной нити.

Чтобы остановить поток, используйте метод close().

Следующий пример выводит использование ЦП в течение десяти секунд. Когда текущая нить выходит из блока try-with-resources, поток останавливается/закрывается.

 try (var stream = new RecordingStream()) {
   stream.enable("jdk.CPULoad").withPeriod(Duration.ofSeconds(1));
   stream.onEvent("jdk.CPULoad", event -> {
     System.out.println(event);
   });
   stream.startAsync();
   Thread.sleep(10_000);
 }
 

Поток записи должен быть запущен, но не закрыт.

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