code: private void safeCommitDataset(Collection<TaskState> taskStates, DataPublisher publisher) {
      synchronized (GLOBAL_LOCK) {
        commitDataset(taskStates, publisher);
      }
    }
docs: Synchronized version of {@link #commitDataset(Collection, DataPublisher)} used when publisher is not
  thread safe.