public long getAllFloatingMemoryUsageInByte() {
    final AtomicLong bytes = new AtomicLong(0);
    pipeMetaKeeper
        .getPipeMetaList()
        .forEach(
            pipeMeta ->
                bytes.addAndGet(
                    ((PipeTemporaryMetaInAgent) pipeMeta.getTemporaryMeta())
                        .getFloatingMemoryUsageInByte()));
    return bytes.get();
  }
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