
<div dir="auto">This was surprising to me as well, as this can lead to some surprising results in environments with unreliable time synchronization. Are there any pointers re discussion why this approach was chosen instead of the more common way of specifying a maximum duration to wait?</div><div dir="auto"><br></div><div dir="auto">Glad to hear that you found a solution, we will need to do something similar when we start using StructuredTaskScopes.</div><div dir="auto"><br></div><div dir="auto">Best Regards,</div><div dir="auto">Sten</div><div dir="auto"><br></div><div dir="auto"><br></div><div><br><div class="gmail_quote"><div dir="ltr" class="gmail_attr">On Tue, Jun 11, 2024 at 18.33 Werner Randelshofer <<a href="mailto:werner.randelshofer@fibermail.ch">werner.randelshofer@fibermail.ch</a>> wrote:<br></div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left-width:1px;border-left-style:solid;padding-left:1ex;border-left-color:rgb(204,204,204)">I have solved my problem. :-)<br>

<br>

I have now implemented a subclass of StructuredTaskScope, which allows to specify a deadline in System.nanoTime() units.<br>

With this design, the deadline is independent from external resources (like NTP time servers) over which the Java process has no control. <br>

<br>

See code below.<br>

<br>

With best regards,<br>

Werner<br>

<br>

<br>

<br>

package org.example.structuredconcurrency;<br>

<br>

import java.time.Duration;<br>

import java.util.concurrent.StructuredTaskScope;<br>

import java.util.concurrent.ThreadFactory;<br>

import java.util.concurrent.TimeoutException;<br>

<br>

/**<br>

Â * A {@link StructuredTaskScope} that supports a deadline given in {@link System#nanoTime()}.<br>

Â *<br>

Â * @param <T> the type of the structured task scope<br>

Â */<br>

public class StructuredTaskScopeNanoTime<T> extends StructuredTaskScope<T> {<br>

<br>

Â  Â  /**<br>

Â  Â  Â * Creates an unnamed structured task scope that creates virtual threads. The task<br>

Â  Â  Â * scope is owned by the current thread.<br>

Â  Â  Â */<br>

Â  Â  public StructuredTaskScopeNanoTime() {<br>

Â  Â  }<br>

<br>

Â  Â  /**<br>

Â  Â  Â * Creates a structured task scope with the given name and thread factory.<br>

Â  Â  Â *<br>

Â  Â  Â * @param nameÂ  Â  the name of the task scope, can be null<br>

Â  Â  Â * @param factory the thread factory<br>

Â  Â  Â */<br>

Â  Â  public StructuredTaskScopeNanoTime(String name, ThreadFactory factory) {<br>

Â  Â  Â  Â  super(name, factory);<br>

Â  Â  }<br>

<br>

Â  Â  /**<br>

Â  Â  Â * Wait for all subtasks started in this task scope to finish or the task scope to<br>

Â  Â  Â * shut down, up to the given deadline.<br>

Â  Â  Â *<br>

Â  Â  Â * @param deadlineNanoTime the deadline given in {@link System#nanoTime()} units<br>

Â  Â  Â * @return this task scope<br>

Â  Â  Â * @throws IllegalStateException if this task scope is closed<br>

Â  Â  Â * @throws WrongThreadExceptionÂ  if the current thread is not the task scope owner<br>

Â  Â  Â * @throws InterruptedExceptionÂ  if interrupted while waiting<br>

Â  Â  Â * @throws TimeoutExceptionÂ  Â  Â  if the deadline is reached while waiting<br>

Â  Â  Â */<br>

Â  Â  public StructuredTaskScopeNanoTime<T> joinUntilNanoTime(long deadlineNanoTime) throws InterruptedException, TimeoutException {<br>

Â  Â  Â  Â  fork(() -> {<br>

Â  Â  Â  Â  Â  Â  Thread.sleep(Duration.ofNanos(deadlineNanoTime - System.nanoTime()));<br>

Â  Â  Â  Â  Â  Â  shutdown();<br>

Â  Â  Â  Â  Â  Â  return null;<br>

Â  Â  Â  Â  });<br>

Â  Â  Â  Â  join();<br>

Â  Â  Â  Â  return this;<br>

Â  Â  }<br>

}<br>

<br>

</blockquote></div></div>