mirror of
https://github.com/usatiuk/dhfs.git
synced 2025-10-29 04:57:48 +01:00
Objects: serialize written objects in parallel
This commit is contained in:
@@ -59,7 +59,7 @@ public class SerializingObjectPersistentStore {
|
|||||||
|
|
||||||
private TxManifestRaw prepareManifest(TxManifestObj<? extends JDataVersionedWrapper> objs) {
|
private TxManifestRaw prepareManifest(TxManifestObj<? extends JDataVersionedWrapper> objs) {
|
||||||
return new TxManifestRaw(
|
return new TxManifestRaw(
|
||||||
objs.written().stream()
|
objs.written().parallelStream()
|
||||||
.map(e -> Pair.of(e.getKey(), serializer.serialize(e.getValue())))
|
.map(e -> Pair.of(e.getKey(), serializer.serialize(e.getValue())))
|
||||||
.toList()
|
.toList()
|
||||||
, objs.deleted());
|
, objs.deleted());
|
||||||
|
|||||||
Reference in New Issue
Block a user