net.openhft.chronicle.bytes.Bytes.tryReserve()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(1.9k)|赞(0)|评价(0)|浏览(81)

本文整理了Java中net.openhft.chronicle.bytes.Bytes.tryReserve()方法的一些代码示例,展示了Bytes.tryReserve()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bytes.tryReserve()方法的具体详情如下:
包路径:net.openhft.chronicle.bytes.Bytes
类名称:Bytes
方法名:tryReserve

Bytes.tryReserve介绍

暂无

代码示例

代码示例来源:origin: OpenHFT/Chronicle-Queue

@Override
public void writeEOF(@NotNull Wire wire, long timeoutMS) {
  // just in case we are about to release this
  if (wire.bytes().tryReserve()) {
    wire.writeEndOfWire(timeoutMS, TimeUnit.MILLISECONDS, writePosition());
    wire.bytes().release();
  } else {
    Jvm.debug().on(getClass(), "Tried to writeEOF to as it was being closed");
  }
}

代码示例来源:origin: net.openhft/chronicle-bytes

@Override
public boolean tryReserve() {
  text.tryReserve();
  return base.tryReserve();
}

代码示例来源:origin: net.openhft/chronicle-queue

@Override
public boolean writeEOF(@NotNull Wire wire, long timeoutMS) {
  String fileName = mappedFile.file().getAbsolutePath();
  // just in case we are about to release this
  if (wire.bytes().tryReserve()) {
    try {
      wire.writeEndOfWire(timeoutMS, TimeUnit.MILLISECONDS, writePosition());
      if (wire.bytes().writePosition() > 4 && Wires.isEndOfFile(wire.bytes().readVolatileInt(wire.bytes().writePosition() - 4))) {
        // only if we just written EOF
        QueueFileShrinkManager.scheduleShrinking(mappedFile.file(), wire.bytes().writePosition());
        return true;
      }
    } finally {
      wire.bytes().release();
    }
  } else {
    try (MappedBytes bytes = MappedBytes.mappedBytes(mappedFile.file(), mappedFile.chunkSize())) {
      Wire wire0 = WireType.valueOf(wire).apply(bytes);
      wire0.writeEndOfWire(timeoutMS, TimeUnit.MILLISECONDS, writePosition());
      if (wire.bytes().writePosition() > 4 && Wires.isEndOfFile(wire.bytes().readVolatileInt(wire.bytes().writePosition() - 4))) {
        QueueFileShrinkManager.scheduleShrinking(mappedFile.file(), wire.bytes().writePosition());
        return true;
      }
    } catch (Exception e) {
      Jvm.warn().on(getClass(), "unable to write the EOF file=" + fileName, e);
    }
  }
  return false;
}

相关文章

微信公众号

最新文章

更多