Хроники байтов разделяют DirectBytesStores - PullRequest
Новая
       13

Хроники байтов разделяют DirectBytesStores

0 голосов
/ 17 октября 2018

Я создал экземпляр MappedBytes для файла, который я использую в качестве общего кэша между различными процессами Java.

Я хотел бы иметь возможность выделить дополнительные экземпляры MappedByte (или ByteBuffer илилюбой другой экземпляр) из оригинала, который обеспечивает прямой доступ для чтения / записи к подмножеству базового файла.

Я провел сегодня, экспериментируя с различными методами, но такими опциями, как subBytes(), rawCopy() и copyTo() кажется, что все создают локальные копии базового файла, а не обращаются к нему напрямую.

Например: 

File tmpFile = new File(System.getProperty("java.io.tmpdir"), "data.dat");
MappedFile mappedFile = MappedFile.mappedFile(tmpfile, 1000, 100, 10, false);
MappedBytes original = MappedBytes.mappedBytes(mappedFile);
original.zeroOut(0, 1000);

original.writeInt(0, 1234);
BytesStore copy = original.bytesStore().subBytes(0, 200);

// Print out the int in the two BytesStores.
// This shows that the copy has the same contents of the original.
System.out.println("Original(0): " + original.readInt(0));
System.out.println("Copy(0): " + copy.readInt(0));

// Now modify the copy and print out the new int in the two BytesStores again.
copy.writeInt(50, 4321);
System.out.println("Original(50): " + original.readInt(50));
System.out.println("Copy(50): " + copy.readInt(50));

Выводит: 

Original(0): 1234
Copy(0): 1234
Original(50): 0
Copy(50): 4321

Копия была изменена, но не оригинал.Я хотел бы, чтобы оригинал был изменен, могут ли хронические байты сделать это?

Спасибо за вашу помощь, Джош.

1 Ответ

0 голосов
/ 17 октября 2018

Это автономный тест, который, я думаю, ведет себя так, как вам нужно. 

@Test
public void multiBytes() throws FileNotFoundException {
    String tmpfile = OS.TMP +  "/data.dat";
    MappedFile mappedFile = MappedFile.mappedFile(new File(tmpfile), 64 << 10);
    MappedBytes original = MappedBytes.mappedBytes(mappedFile);
    original.zeroOut(0, 1000);

    original.writeInt(0, 1234);

    PointerBytesStore pbs = new PointerBytesStore();
    pbs.set(original.addressForRead(50), 100);

    // Print out the int in the two BytesStores.
    // This shows that the copy has the same contents of the original.
    System.out.println("Original(0): " + original.readInt(0));
    System.out.println("PBS(0): " + pbs.readInt(0));

    // Now modify the copy and print out the new int in the two BytesStores again.
    pbs.writeInt(0, 4321);
    System.out.println("Original(50): " + original.readInt(50));
    System.out.println("PBS(0): " + pbs.readInt(0));
    original.writeInt(54, 12345678);
    System.out.println("Original(54): " + original.readInt(54));
    System.out.println("PBS(4): " + pbs.readInt(4));
}

отпечатки 

Original(0): 1234
PBS(0): 0
Original(50): 4321
PBS(0): 4321
Original(54): 12345678
PBS(4): 12345678
...