mirrors/Terra
1
0
Fork 0
mirror of https://github.com/PolyhedralDev/Terra.git synced 2026-06-19 23:31:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

parallel pack loading

Browse Source
This commit is contained in:
Zoë Gidiere
2025-10-09 17:55:29 -06:00
parent 1fe56335c8
commit c3d26527a7
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/implementation/base/src/main/java/com/dfsek/terra/registry/master/ConfigRegistry.java
+3 -2
View File
@@ -23,6 +23,7 @@ import java.nio.file.Files;
import java.nio.file.Path; import java.nio.file.Path;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.stream.Stream; import java.util.stream.Stream;
import com.dfsek.terra.api.Platform; import com.dfsek.terra.api.Platform;
@@ -44,9 +45,9 @@ public class ConfigRegistry extends OpenRegistryImpl<ConfigPack> {
public synchronized void loadAll(Platform platform) throws IOException, PackLoadFailuresException { public synchronized void loadAll(Platform platform) throws IOException, PackLoadFailuresException {
Path packsDirectory = platform.getDataFolder().toPath().resolve("packs"); Path packsDirectory = platform.getDataFolder().toPath().resolve("packs");
Files.createDirectories(packsDirectory); Files.createDirectories(packsDirectory);
List<Exception> failedLoads = new ArrayList<>(); List<Exception> failedLoads = new CopyOnWriteArrayList<>();
try(Stream<Path> packs = Files.list(packsDirectory)) { try(Stream<Path> packs = Files.list(packsDirectory)) {
packs.forEach(path -> { packs.parallel().forEach(path -> {
try { try {
ConfigPack pack = new ConfigPackImpl(path, platform); ConfigPack pack = new ConfigPackImpl(path, platform);
registerChecked(pack.getRegistryKey(), pack); registerChecked(pack.getRegistryKey(), pack);