本文整理了Java中net.openhft.chronicle.bytes.Bytes.tryReserve()
方法的一些代码示例,展示了Bytes.tryReserve()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bytes.tryReserve()
方法的具体详情如下:
包路径:net.openhft.chronicle.bytes.Bytes
类名称: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;
}
内容来源于网络,如有侵权,请联系作者删除!