mirror of
https://github.com/VolmitSoftware/Iris.git
synced 2026-06-17 14:21:33 +00:00
e
This commit is contained in:
@@ -443,7 +443,6 @@ public class Mantle {
|
|||||||
dynamicThreads.set(IrisSettings.get().getPerformance().getTectonicUnloadThreads());
|
dynamicThreads.set(IrisSettings.get().getPerformance().getTectonicUnloadThreads());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
int dth = dynamicThreads.get();
|
|
||||||
|
|
||||||
adjustedIdleDuration.set(baseIdleDuration);
|
adjustedIdleDuration.set(baseIdleDuration);
|
||||||
|
|
||||||
@@ -501,10 +500,10 @@ public class Mantle {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// BurstExecutor burstExecutor = new BurstExecutor(Executors.newFixedThreadPool(1), toUnload.size());
|
BurstExecutor burstExecutor = new BurstExecutor(Executors.newFixedThreadPool(dynamicThreads.get()), toUnload.size());
|
||||||
|
|
||||||
for (Long i : toUnload) {
|
for (Long i : toUnload) {
|
||||||
// burstExecutor.queue(() -> {
|
burstExecutor.queue(() -> {
|
||||||
hyperLock.withLong(i, () -> {
|
hyperLock.withLong(i, () -> {
|
||||||
TectonicPlate m = loadedRegions.get(i);
|
TectonicPlate m = loadedRegions.get(i);
|
||||||
if (m != null) {
|
if (m != null) {
|
||||||
@@ -519,10 +518,9 @@ public class Mantle {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
// });
|
});
|
||||||
}
|
}
|
||||||
// burstExecutor.complete();
|
burstExecutor.complete();
|
||||||
|
|
||||||
} finally {
|
} finally {
|
||||||
io.set(false);
|
io.set(false);
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user