stan/jdk-24
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

8297006: JFR: AbstractEventStream should not hold thread instance

Browse Source 
Reviewed-by: mgronlun
This commit is contained in:
Erik Gahlin 2022-11-16 20:01:37 +00:00
parent 5db1b58c86
commit 04a4d347bd
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/jdk.jfr/share/classes/jdk/jfr/internal/consumer/AbstractEventStream.java
View File

@ -1,5 +1,5 @@
/* /*
* Copyright (c) 2019, 2021, Oracle and/or its affiliates. All rights reserved. * Copyright (c) 2019, 2022, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
@ -62,7 +62,6 @@ public abstract class AbstractEventStream implements EventStream {
private final StreamConfiguration streamConfiguration = new StreamConfiguration(); private final StreamConfiguration streamConfiguration = new StreamConfiguration();
private final List<Configuration> configurations; private final List<Configuration> configurations;
private final ParserState parserState = new ParserState(); private final ParserState parserState = new ParserState();
private volatile Thread thread;
private Dispatcher dispatcher; private Dispatcher dispatcher;
private boolean daemon = false; private boolean daemon = false;
@ -214,14 +213,13 @@ public abstract class AbstractEventStream implements EventStream {
public final void startAsync(long startNanos) { public final void startAsync(long startNanos) {
startInternal(startNanos); startInternal(startNanos);
Runnable r = () -> run(accessControllerContext); Runnable r = () -> run(accessControllerContext);
thread = SecuritySupport.createThreadWitNoPermissions(nextThreadName(), r); Thread thread = SecuritySupport.createThreadWitNoPermissions(nextThreadName(), r);
SecuritySupport.setDaemonThread(thread, daemon); SecuritySupport.setDaemonThread(thread, daemon);
thread.start(); thread.start();
} }
public final void start(long startNanos) { public final void start(long startNanos) {
startInternal(startNanos); startInternal(startNanos);
thread = Thread.currentThread();
run(accessControllerContext); run(accessControllerContext);
} }