voxelcoreprojects/voxelcore
1
0
Fork 0
mirror of https://github.com/MihailRis/voxelcore.git synced 2026-10-06 03:21:49 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 9

stabilize delays of chunks meshes building

Browse source
This commit is contained in:
MihailRis 2025-12-29 20:41:47 +03:00
parent f47ccd5f30
commit 88544183d0
13 changed files with 335 additions and 191 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/util/ThreadPool.hpp
View file

@ -52,7 +52,7 @@ namespace util {
bool standaloneResults = true;
bool stopOnFail = true;
void threadLoop(int index, std::shared_ptr<Worker<T, R>> worker) {
void threadLoop(int index, std::unique_ptr<Worker<T, R>> worker) {
std::condition_variable variable;
std::mutex mutex;
bool locked = false;
@ -76,7 +76,7 @@ namespace util {
{
std::lock_guard<std::mutex> lock(resultsMutex);
results.push(ThreadPoolResult<T, R> {
job, variable, index, locked, result});
job, variable, index, locked, std::move(result)});
if (!standaloneResults) {
locked = true;
}
@ -115,7 +115,7 @@ namespace util {
/// unlimited, -2 is half of auto count, -4 is quarter.
ThreadPool(
std::string name,
supplier<std::shared_ptr<Worker<T, R>>> workersSupplier,
supplier<std::unique_ptr<Worker<T, R>>> workersSupplier,
consumer<R&&> resultConsumer,
int maxWorkers=UNLIMITED
)
@ -236,7 +236,7 @@ namespace util {
return resultsProcessed;
}
void enqueueJob(T job) {
void enqueueJob(T&& job) {
{
std::lock_guard<std::mutex> lock(jobsMutex);
jobs.push(std::move(job));