@Async.Execute
  @Override
  public void accept(T t, U u) {
    try (AccessToken ignored = ThreadContext.installThreadContext(myParentContext, !myRoot)) {
      myRunnable.accept(t, u);
    }
  }
@Async.Execute
  @Override
  public void accept(T t, U u)