
<html><head><meta http-equiv="Content-Type" content="text/html; charset=utf-8"></head><body style="word-wrap: break-word; -webkit-nbsp-mode: space; line-break: after-white-space;" class="">I created another more real-world test based on experience in debugging systems/memory leaks. The code is here <a href="https://github.com/robaho/closablequeue/blob/sample/src/main/java/robaho/queue/sample/SampleOrigWithRef.java" class="">https://github.com/robaho/closablequeue/blob/sample/src/main/java/robaho/queue/sample/SampleOrigWithRef.java</a><div class=""><br class=""></div><div class="">At least for me, I have found it useful to take heap dumps / snapshots and check instance count invariants - e.g. number of reader threads should equal the number of Producer objects, etc.</div><div class=""><br class=""></div><div class="">When the lifecycle is not correctly implemented using platform threads, you will get a continual increase in threads and the number of consumer objects. (A)</div><div class=""><br class=""></div><div class="">With VT and tracking turned off, the number of threads and consumer objects will remain constant, but the behavior is not as expected (there is no printing of the stats) (B)</div><div class=""><br class=""></div><div class="">With the lifecycle correctly implemented, the instance count invariant holds and the stats are printed. (C)</div><div class=""><br class=""></div><div class="">You can argue that clearly B is broken because the stats line is not observable but this is only a trivial example and it isn’t always that easy.</div><div class=""><br class=""></div><div class="">I find memory leaks - or lack there of - a decent check of correctness. With this VT change, that will no longer be the case.</div><div class=""><br class=""></div><div style="caret-color: rgb(0, 0, 0); color: rgb(0, 0, 0);" class="">I also don’t like reviewing a piece of code - consumer() in this case - and having to determine if it is correct based on a system property value. This seems against Java’s explicitness (although I realize some system properties already alter behavior greatly).</div><div style="caret-color: rgb(0, 0, 0); color: rgb(0, 0, 0);" class=""><br class=""></div><div class="">As an aside, based on your previous comments, it is curious that the objects are not collected in A. It is in the same state as B - the system knows that queue.take() can never advance - so if the references are not being held by stack entries then they should be collected, right - regardless that a Thread is a GC root?</div><div class=""><br class=""></div><div class="">-----</div><div class=""><div class=""><br class=""></div><div class="">A) With platform thread consumer:</div><div class=""><br class=""></div><div class=""><div class="">0 ThirdActor: Queue created</div><div class="">2 Producer: no queue</div><div class="">4 Producer: enqueued message</div><div class="">4 Consumer 0: message received</div><div class="">6 Producer: enqueued message</div><div class="">6 Consumer 0: message received</div><div class="">6 Consumer 0: close shop</div><div class="">8 Producer: enqueued message</div><div class="">8 Consumer 0: message received</div><div class="">10 Producer: no queue</div><div class="">12 ThirdActor: Queue created</div><div class="">12 Producer: no queue</div><div class="">14 Producer: enqueued message</div><div class="">14 Consumer 12: message received</div><div class="">16 Producer: enqueued message</div><div class="">16 Consumer 12: message received</div><div class="">16 Consumer 12: close shop</div><div class="">18 Producer: enqueued message</div><div class="">18 Consumer 12: message received</div><div class="">20 Producer: no queue</div><div class="">22 Producer: no queue</div><div class="">24 ThirdActor: Queue created</div><div class="">24 Producer: no queue</div><div class="">26 Producer: enqueued message</div><div class="">26 Consumer 24: message received</div><div class="">28 Producer: enqueued message</div><div class="">28 Consumer 24: message received</div><div class="">28 Consumer 24: close shop</div><div class=""><br class=""></div><div class="">B) and with virtual thread consumer and tracking turned off:</div><div class=""><br class=""></div><div class="">0 ThirdActor: Queue created<br class="">2 Producer: no queue<br class="">4 Producer: enqueued message<br class="">4 Consumer 0: message received<br class="">6 Producer: enqueued message<br class="">6 Consumer 0: message received<br class="">6 Consumer 0: close shop<br class="">8 Producer: enqueued message<br class="">8 Consumer 0: message received<br class="">10 Producer: no queue<br class="">12 Producer: no queue<br class="">12 ThirdActor: Queue created<br class="">consumer object collected: java.lang.ref.PhantomReference@7d52c835, thread count 13<br class="">queue collected: java.lang.ref.PhantomReference@4a02d483, thread count 13<br class="">14 Producer: enqueued message<br class="">14 Consumer 12: message received<br class="">16 Producer: enqueued message<br class="">16 Consumer 12: message received<br class="">16 Consumer 12: close shop<br class="">18 Producer: enqueued message<br class="">18 Consumer 12: message received<br class="">20 Producer: no queue<br class="">22 Producer: no queue<br class="">24 ThirdActor: Queue created<br class="">consumer object collected: java.lang.ref.PhantomReference@26e0c418, thread count 13<br class="">queue collected: java.lang.ref.PhantomReference@60aece00, thread count 13<br class="">24 Producer: no queue<br class="">26 Producer: enqueued message</div><div class=""><br class=""></div><div class="">C) and with either type and correct lifecycle code:</div><div class=""><br class=""></div><div class=""><div class="">0 ThirdActor: Queue created</div><div class="">2 Producer: no queue</div><div class="">4 Producer: enqueued message</div><div class="">4 Consumer 0: message received</div><div class="">6 Producer: enqueued message</div><div class="">6 Consumer 0: message received</div><div class="">6 Consumer 0: close shop</div><div class="">8 Producer: enqueued message</div><div class="">8 Consumer 0: message received</div><div class="">10 Producer: no queue</div><div class="">12 Producer: no queue</div><div class=""><b class="">consumer 0 interrupted</b></div><div class=""><b class="">consumer ended, stats = 3</b></div><div class="">12 ThirdActor: Queue created</div><div class="">queue collected: java.lang.ref.PhantomReference@4a02d483, thread count 13</div><div class="">consumer object collected: java.lang.ref.PhantomReference@7d52c835, thread count 13</div><div class="">14 Producer: no queue</div><div class="">16 Producer: enqueued message</div><div class="">16 Consumer 12: message received</div><div class="">18 Producer: enqueued message</div><div class="">18 Consumer 12: message received</div><div class="">18 Consumer 12: close shop</div><div class="">20 Producer: enqueued message</div><div class="">20 Consumer 12: message received</div><div class="">22 Producer: no queue</div><div class="">24 Producer: no queue</div><div class=""><b class="">consumer 12 interrupted</b></div><div class=""><b class="">consumer ended, stats = 3</b></div><div class="">24 ThirdActor: Queue created</div><div class="">queue collected: java.lang.ref.PhantomReference@79a8a792, thread count 13</div><div class="">consumer object collected: java.lang.ref.PhantomReference@4af7de55, thread count 13</div><div class="">26 Producer: no queue</div><div class="">28 Producer: enqueued message</div><div class="">28 Consumer 24: message received</div></div><div><br class=""><blockquote type="cite" class=""><div class="">On Aug 1, 2024, at 12:11 PM, Ron Pressler <<a href="mailto:ron.pressler@oracle.com" class="">ron.pressler@oracle.com</a>> wrote:</div><br class="Apple-interchange-newline"><div class=""><meta charset="UTF-8" class=""><br style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none;" class=""><br style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none;" class=""><blockquote type="cite" style="font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: auto; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; widows: auto; word-spacing: 0px; -webkit-text-size-adjust: auto; -webkit-text-stroke-width: 0px; text-decoration: none;" class="">On 1 Aug 2024, at 10:41, robert engels <<a href="mailto:robaho@icloud.com" class="">robaho@icloud.com</a>> wrote:<br class=""><br class="">I was not aware of that! So are you saying that current JVMs will GC or not even create A in the following:<br class=""><br class="">A a = …<br class="">while(true) {<br class="">…never reference A…<br class="">}<br class="">a.doSomething();<br class=""><br class=""></blockquote><br style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none;" class=""><span style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none; float: none; display: inline !important;" class="">That depends on whether or not the VM is able to prove that the loop can never be exited (or if it is, then only through an exception that won’t be caught before a.doSomething, which also depends on the inference power of the implementation. But if the VM could prove that, then the object referenced by A is allowed to be collected (that is exactly what ReachabilityFence is for, although that API has some problems we won’t get into here).</span><br style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none;" class=""><br style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none;" class=""><span style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none; float: none; display: inline !important;" class="">The rule is that when you access an object through a strong reference it will be there. The converse is that the VM may collect an object that will provably never be accessed through a strong reference. The rest is implementation details (and ReachabilityFence, which is problematic in multiple ways, including in how it’s specified).</span><br style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none;" class=""><br style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none;" class=""><span style="caret-color: rgb(0, 0, 0); font-family: Helvetica; font-size: 16px; font-style: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; text-align: start; text-indent: 0px; text-transform: none; white-space: normal; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration: none; float: none; display: inline !important;" class="">— Ron</span></div></blockquote></div><br class=""></div></div></body></html>