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

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

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

Bytes.clear介绍

暂无

代码示例

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

@Override
public void accept(final WireIn wireIn, final Consumer<String> messageHandler) {
  long elementCount = 0;
  while (wireIn.hasMore()) {
    new BinaryWire(wireIn.bytes()).copyOne(wireType.apply(textConversionTarget));
    elementCount++;
    if ((elementCount & 1) == 0) {
      messageHandler.accept(textConversionTarget.toString());
      textConversionTarget.clear();
    }
  }
}

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

@Override
public void accept(final WireIn wireIn, final Consumer<String> messageHandler) {
  final Bytes<?> serialisedMessage = wireIn.bytes();
  final byte dataFormatIndicator = serialisedMessage.readByte(serialisedMessage.readPosition());
  String text;
  if (isBinaryFormat(dataFormatIndicator)) {
    textConversionTarget.clear();
    final BinaryWire binaryWire = new BinaryWire(serialisedMessage);
    binaryWire.copyTo(wireType.apply(textConversionTarget));
    text = textConversionTarget.toString();
  } else {
    text = serialisedMessage.toString();
  }
  messageHandler.accept(text);
}

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

private void append() {
  outbound.clear();
  outbound.write(new byte[msgSize], 0, msgSize);
  appender.writeBytes(outbound);
}

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

bytes.clear();
if (tailer.readBytes(bytes))
  counter.incrementAndGet();
message.clear();
message.append(i);
appender.writeBytes(message);

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

@Test
public void testWriteBytes() {
  File dir = DirectoryUtils.tempDir("WriteBytesTest");
  try (ChronicleQueue queue = binary(dir)
      .testBlockSize()
      .build()) {
    ExcerptAppender appender = queue.acquireAppender();
    ExcerptTailer tailer = queue.createTailer();
    outgoingMsgBytes[0] = 'A';
    outgoingBytes.write(outgoingMsgBytes);
    postOneMessage(appender);
    fetchOneMessage(tailer, incomingMsgBytes);
    System.out.println(new String(incomingMsgBytes));
    outgoingBytes.clear();
    outgoingMsgBytes[0] = 'A';
    outgoingMsgBytes[1] = 'B';
    outgoingBytes.write(outgoingMsgBytes);
    postOneMessage(appender);
    fetchOneMessage(tailer, incomingMsgBytes);
    System.out.println(new String(incomingMsgBytes));
  } finally {
    try {
      IOTools.deleteDirWithFiles(dir, 2);
    } catch (IORuntimeException e) {
      // ignored
    }
  }
}

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

for (long i = 0; i < count; i++) {
  try (DocumentContext dc = tailer.readingDocument()) {
    bytes.clear();
    bytes.write(dc.wire().bytes());

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

@Test
public void testSimpleByteTest() {
  assumeFalse(Jvm.isArm());
  try (final ChronicleQueue chronicle = builder(getTmpDir(), wireType)
      .rollCycle(TEST2_DAILY)
      .build()) {
    final ExcerptAppender appender = chronicle.acquireAppender();
    Bytes steve = Bytes.allocateDirect("Steve".getBytes());
    appender.writeBytes(steve);
    Bytes jobs = Bytes.allocateDirect("Jobs".getBytes());
    appender.writeBytes(jobs);
    final ExcerptTailer tailer = chronicle.createTailer();
    Bytes bytes = Bytes.elasticByteBuffer();
    try {
      tailer.readBytes(bytes);
      Assert.assertEquals("Steve", bytes.toString());
      bytes.clear();
      tailer.readBytes(bytes);
      Assert.assertEquals("Jobs", bytes.toString());
    } finally {
      steve.release();
      jobs.release();
      bytes.release();
    }
  }
}

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

for (long i = 0; i < count; i++) {
  try (DocumentContext dc = tailer.readingDocument()) {
    bytes.clear();
    bytes.write(dc.wire().bytes());

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

@Test//(timeout = 5000)
public void testTailerReadingEmptyQueue() {
  assumeFalse(Jvm.isArm());
  final File path = DirectoryUtils.tempDir("testTailerReadingEmptyQueue");
  final ChronicleQueue rqueue = SingleChronicleQueueBuilder.fieldlessBinary(path)
      .testBlockSize()
      .rollCycle(TEST_DAILY)
      .build();
  final ExcerptTailer tailer = rqueue.createTailer();
  final ChronicleQueue wqueue = SingleChronicleQueueBuilder.fieldlessBinary(path)
      .testBlockSize()
      .rollCycle(TEST_DAILY)
      .build();
  Bytes bytes = Bytes.elasticByteBuffer();
  assertFalse(tailer.readBytes(bytes));
  final ExcerptAppender appender = wqueue.acquireAppender();
  appender.writeBytes(Bytes.wrapForRead("Hello World".getBytes(ISO_8859_1)));
  bytes.clear();
  assertTrue(tailer.readBytes(bytes));
  assertEquals("Hello World", bytes.toString());
  bytes.release();
}

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

private void initBytes() {
  if (!bytesInit) {
    bytes.clear();
    instance.writeMarshallable(bytes);
    bytesInit = true;
  }
}

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

@Override
public Data<T> getData(@NotNull T cs) {
  this.cs = cs;
  bytes.clear();
  BytesUtil.appendUtf8(bytes, cs);
  return this;
}

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

@Override
public Data<T> getData(@NotNull T instance) {
  this.instance = instance;
  bytes.clear();
  try {
    ObjectOutputStream out = new ObjectOutputStream(this.out);
    instance.writeExternal(out);
    out.flush();
    return this;
  } catch (IOException e) {
    throw new RuntimeException(e);
  }
}

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

@Override
public boolean put(String key, @NotNull String value) {
  Buffers b = BUFFERS.get();
  Bytes<ByteBuffer> bytes = b.valueBuffer;
  bytes.clear();
  bytes.append8bit(value);
  return kvStore.put(key, bytes);
}

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

@Override
public RandomDataInput bytes() {
  if (!bytesInit) {
    bytes.clear();
    sizedWriter.write(bytes, size, instance);
    bytesInit = true;
  }
  return bytes.bytesStore();
}

代码示例来源：origin: peter-lawrey/Performance-Examples

@Benchmark
  public long usingBytes() throws IOException, ClassNotFoundException {
    bytes.clear();
    bytes.writeLong(System.currentTimeMillis());
    return bytes.readLong();
  }
}

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

@ForceInline
public static void parse8bit(@org.jetbrains.annotations.NotNull @NotNull StreamingDataInput bytes, @org.jetbrains.annotations.NotNull @NotNull Bytes builder, @org.jetbrains.annotations.NotNull @NotNull StopCharTester tester)
    throws BufferUnderflowException, BufferOverflowException {
  builder.clear();
  read8bitAndAppend(bytes, builder, tester);
}

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

@Override
public void accept(final WireIn wireIn, final Consumer<String> messageHandler) {
  long elementCount = 0;
  while (wireIn.hasMore()) {
    new BinaryWire(wireIn.bytes()).copyOne(wireType.apply(textConversionTarget));
    elementCount++;
    if ((elementCount & 1) == 0) {
      messageHandler.accept(textConversionTarget.toString());
      textConversionTarget.clear();
    }
  }
}

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

default void readWithLength(Bytes bytes) {
  bytes.clear();
  int length = Maths.toUInt31(readStopBit());
  int i;
  for (i = 0; i < length - 7; i++)
    bytes.writeLong(readLong());
  for (; i < length; i++)
    bytes.writeByte(readByte());
}

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

void initSegment() {
  boolean wasSegmentInit = this.segmentInit();
  VanillaChronicleHash<?, ?, ?, ?> h = this.h();
  long segmentBaseAddr = this.tierBaseAddr();
  segmentBS.set(segmentBaseAddr, h.tierSize);
  segmentBytes.clear();
  long freeListOffset = (h.tierHashLookupOuterSize) + (VanillaChronicleHash.TIER_COUNTERS_AREA_SIZE);
  freeList.setOffset((segmentBaseAddr + freeListOffset));
  entrySpaceOffset = (freeListOffset + (h.tierFreeListOuterSize)) + (h.tierEntrySpaceInnerOffset);
  if (wasSegmentInit)
    this.closeSegmentDependants();
  
}

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

private void newLine() {
  if (this.comment.readRemaining() > 0) {
    while (lineLength() < numberWrap * 3 - 3)
      this.text.append("   ");
    while (lineLength() < numberWrap * 3)
      this.text.append(' ');
    this.text.append("# ");
    this.text.append(comment);
    comment.clear();
  }
  this.text.append('\n');
  startOfLine = this.text.writePosition();
}

内容来源于网络，如有侵权，请联系作者删除！

Bytes

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    Bytes类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com