Класс RecordingStream

public RecordingStream()

Исключения:

IllegalStateException — если не удается создать Flight Recorder (например, если виртуальная машина Java (JVM) не поддерживает Flight Recorder или если не удается создать репозиторий файлов либо получить к нему доступ)

public RecordingStream(Configuration configuration)

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

Параметры:

configuration — конфигурация, содержащая используемые параметры; значение не должно быть null

Исключения:

IllegalStateException — если не удается создать Flight Recorder (например, если виртуальная машина Java (JVM) не поддерживает Flight Recorder или если не удается создать репозиторий файлов либо получить к нему доступ)

См. также:

• Configuration

public EventSettings enable(String name)

Параметры:

name — параметры события; значение не должно быть null

Возвращает:

параметр события для дальнейшей настройки; значение не должно быть null

См. также:

• EventType

public void setSettings(Map<String,String> settings)

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);
}

Параметры:

settings — задаваемые параметры; значение не должно быть null

См. также:

• Recording.setSettings(Map)

public EventSettings enable(Class<? extends Event> eventClass)

Параметры:

eventClass — включаемое событие; значение не должно быть null

Возвращает:

параметр события для дальнейшей настройки; значение не должно быть null

Исключения:

IllegalArgumentException — если eventClass является абстрактным классом или не является подклассом Event

public EventSettings disable(String name)

Параметры:

name — параметры события; значение не должно быть null

Возвращает:

параметр события для дальнейшей настройки; значение не должно быть null

public EventSettings disable(Class<? extends Event> eventClass)

Параметры:

eventClass — отключаемое событие; значение не должно быть null

Возвращает:

параметр события для дальнейшей настройки; значение не должно быть null

Исключения:

IllegalArgumentException — если eventClass является абстрактным классом или не является подклассом Event

public void setMaxAge(Duration maxAge)

Параметры:

maxAge — срок хранения данных или null для неограниченного срока

Исключения:

IllegalArgumentException — если maxAge отрицательно

IllegalStateException — если запись находится в состоянии CLOSED

public void setMaxSize(long maxSize)

Параметры:

maxSize — объем сохраняемых данных; 0 означает отсутствие ограничений

Исключения:

IllegalArgumentException — если maxSize отрицательно

IllegalStateException — если запись находится в состоянии CLOSED

public void setReuse(boolean reuse)

Определено в:

setReuse в интерфейсе EventStream

Параметры:

reuse — true, если объект события можно использовать повторно; в противном случае — false

public void setOrdered(boolean ordered)

Определено в:

setOrdered в интерфейсе EventStream

Параметры:

ordered — указывает, поступают ли объекты событий в хронологическом порядке в EventStream.onEvent(Consumer)

public void setStartTime(Instant startTime)

Определено в:

setStartTime в интерфейсе EventStream

Параметры:

startTime — время начала; значение не должно быть null

См. также:

• EventStream.start()
• EventStream.startAsync()

public void setEndTime(Instant endTime)

Определено в:

setEndTime в интерфейсе EventStream

Параметры:

endTime — время окончания; значение не должно быть null

См. также:

• EventStream.start()
• EventStream.startAsync()

public void onEvent(String eventName, Consumer<RecordedEvent> action)

Определено в:

onEvent в интерфейсе EventStream

Параметры:

eventName — имя события; значение не должно быть null

action — действие, выполняемое для каждого RecordedEvent, соответствующего имени события; значение не должно быть null

public void onEvent(Consumer<RecordedEvent> action)

Определено в:

onEvent в интерфейсе EventStream

Параметры:

action — действие, выполняемое для каждого RecordedEvent; значение не должно быть null

См. также:

• EventStream.onEvent(Consumer)
• EventStream.onMetadata(Consumer)

public void onFlush(Runnable action)

Определено в:

onFlush в интерфейсе EventStream

Параметры:

action — действие, выполняемое после сброса потока; значение не должно быть null

public void onClose(Runnable action)

Определено в:

onClose в интерфейсе EventStream

Параметры:

action — действие, выполняемое после закрытия потока; значение не должно быть null

См. также:

• EventStream.close()

public void onError(Consumer<Throwable> action)

Определено в:

onError в интерфейсе EventStream

Параметры:

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

public void close()

Определено в:

close в интерфейсе AutoCloseable

Определено в:

close в интерфейсе EventStream

public boolean remove(Object action)

Определено в:

remove в интерфейсе EventStream

Параметры:

action — действие, регистрацию которого необходимо отменить; значение не должно быть null

Возвращает:

true, если регистрация действия была отменена; в противном случае — false

См. также:

• EventStream.onEvent(Consumer)
• EventStream.onEvent(String, Consumer)
• EventStream.onFlush(Runnable)
• EventStream.onClose(Runnable)
• EventStream.onError(Consumer)

public void start()

Определено в:

start в интерфейсе EventStream

public void startAsync()

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);
}

Определено в:

startAsync в интерфейсе EventStream

Исключения:

IllegalStateException — если поток уже запущен или закрыт

public boolean stop()

AtomicBoolean socketUse = new AtomicBoolean();
try (var r = new RecordingStream()) {
    r.setMaxSize(Long.MAX_VALUE);
    r.enable("jdk.SocketWrite").withoutThreshold();
    r.enable("jdk.SocketRead").withoutThreshold();
    r.onEvent(event -> socketUse.set(true));
    r.startAsync();
    testFoo();
    r.stop();
    if (socketUse.get()) {
        r.dump(Path.of("socket-events.jfr"));
        throw new AssertionError("testFoo() should not use network");
    }
}

Возвращает:

true, если запись остановлена; в противном случае — false

Исключения:

IllegalStateException — если запись не запущена или уже остановлена

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

20

public void dump(Path destination) throws IOException

Параметры:

destination — расположение для записи данных записи; значение не должно быть null

Исключения:

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

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

17

См. также:

• setMaxAge(Duration)
• setMaxSize(long)

public void awaitTermination(Duration timeout) throws InterruptedException

Определено в:

awaitTermination в интерфейсе EventStream

Параметры:

timeout — максимальное время ожидания; значение не должно быть null

Исключения:

InterruptedException — если ожидание было прервано

См. также:

• EventStream.start()
• EventStream.startAsync()
• Thread.interrupt()

public void awaitTermination() throws InterruptedException

Определено в:

awaitTermination в интерфейсе EventStream

Исключения:

InterruptedException — если ожидание было прервано

См. также:

• EventStream.start()
• EventStream.startAsync()
• Thread.interrupt()

public void onMetadata(Consumer<MetadataEvent> action)

static long count = 0;
public static void main(String... args) throws Exception {
    String regExp = args[0];
    var pr = Pattern.compile(regExp).asMatchPredicate();
    Configuration c = Configuration.getConfiguration("default");
    try (var s = new RecordingStream(c)) {
        s.setOrdered(false);
        s.onMetadata(metadata -> metadata.getAddedEventTypes()
         .stream().map(EventType::getName).filter(pr)
         .forEach(eventName -> s.onEvent(eventName, event -> count++)));
        s.startAsync();
        System.out.println("Running recording for 5 s. Please wait.");
        s.awaitTermination(Duration.ofSeconds(5));
        System.out.println(count + " events matches " + regExp);
    }
}

Определено в:

onMetadata в интерфейсе EventStream

Параметры:

action — действие для выполнения; значение не должно быть null

Исключения:

IllegalStateException — если действие добавлено после запуска потока

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

16