public void decreaseFloatingMemoryUsageInByte(final String pipeName, final long sizeInByte) {
    final PipeMeta pipeMeta = pipeMetaKeeper.getPipeMeta(pipeName);
    if (Objects.nonNull(pipeMeta)) {
      ((PipeTemporaryMetaInAgent) pipeMeta.getTemporaryMeta())
          .decreaseFloatingMemoryUsageInByte(sizeInByte);
    }
  }
Using try lock method to prevent deadlock when stopping all pipes with critical exceptions and
{@link PipeTaskAgent#handlePipeMetaChanges(List)}} concurrently.
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/PipeTaskAgent.java