|
1 | 1 | /* |
2 | | - * Copyright (c) 2019, 2021, Oracle and/or its affiliates. All rights reserved. |
| 2 | + * Copyright (c) 2019, 2022, Oracle and/or its affiliates. All rights reserved. |
3 | 3 | * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. |
4 | 4 | * |
5 | 5 | * This code is free software; you can redistribute it and/or modify it |
@@ -62,7 +62,6 @@ public abstract class AbstractEventStream implements EventStream { |
62 | 62 | private final StreamConfiguration streamConfiguration = new StreamConfiguration(); |
63 | 63 | private final List<Configuration> configurations; |
64 | 64 | private final ParserState parserState = new ParserState(); |
65 | | - private volatile Thread thread; |
66 | 65 | private Dispatcher dispatcher; |
67 | 66 | private boolean daemon = false; |
68 | 67 |
|
@@ -214,14 +213,13 @@ protected final ParserState parserState() { |
214 | 213 | public final void startAsync(long startNanos) { |
215 | 214 | startInternal(startNanos); |
216 | 215 | Runnable r = () -> run(accessControllerContext); |
217 | | - thread = SecuritySupport.createThreadWitNoPermissions(nextThreadName(), r); |
| 216 | + Thread thread = SecuritySupport.createThreadWitNoPermissions(nextThreadName(), r); |
218 | 217 | SecuritySupport.setDaemonThread(thread, daemon); |
219 | 218 | thread.start(); |
220 | 219 | } |
221 | 220 |
|
222 | 221 | public final void start(long startNanos) { |
223 | 222 | startInternal(startNanos); |
224 | | - thread = Thread.currentThread(); |
225 | 223 | run(accessControllerContext); |
226 | 224 | } |
227 | 225 |
|
|
0 commit comments