private void cleanTmpFile() {
    String pipeLineSortDir =
        IoTDBDescriptor.getInstance().getConfig().getSortTmpDir()
            + File.separator
            + driverContext.getFragmentInstanceContext().getId().getFullId()
            + File.separator
            + driverContext.getPipelineId()
            + File.separator;
    File tmpPipeLineDir = new File(pipeLineSortDir);
    if (!tmpPipeLineDir.exists()) {
      return;
    }
    FileUtils.deleteFileOrDirectory(tmpPipeLineDir, true);
  }
Try to acquire the {@code exclusiveLock} with {@code timeout} and run a {@code task}. If the
{@code interruptOnClose} flag is set to {@code true} the {@code task} will be interrupted if
the {@code Driver} is closed.

<p>Note: task cannot return null
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/driver/Driver.java