Mirror von
https://github.com/IntellectualSites/FastAsyncWorldEdit.git
synchronisiert 2024-11-19 17:30:08 +01:00
Add comment
Dieser Commit ist enthalten in:
Ursprung
08156a3d14
Commit
7f34eec567
@ -443,12 +443,17 @@ public class PaperweightGetBlocks extends CharGetBlocks implements BukkitGetBloc
|
|||||||
if (chunk != null) {
|
if (chunk != null) {
|
||||||
return internalCall(set, finalizer, chunk, nmsWorld);
|
return internalCall(set, finalizer, chunk, nmsWorld);
|
||||||
}
|
}
|
||||||
|
// Submit via the STQE as that will help handle excessive queuing by waiting for the submission count to fall below the
|
||||||
|
// target size
|
||||||
nmsChunkFuture.thenApply(nmsChunk -> owner.submitTaskUnchecked(() -> (T) internalCall(
|
nmsChunkFuture.thenApply(nmsChunk -> owner.submitTaskUnchecked(() -> (T) internalCall(
|
||||||
set,
|
set,
|
||||||
finalizer,
|
finalizer,
|
||||||
nmsChunk,
|
nmsChunk,
|
||||||
nmsWorld
|
nmsWorld
|
||||||
)));
|
)));
|
||||||
|
// If we have re-submitted, return a completed future to prevent potential deadlocks where a future reliant on the
|
||||||
|
// above submission is halting the BlockingExecutor, and preventing the above task from actually running. The futures
|
||||||
|
// submitted above will still be added to the STQE submissions.
|
||||||
return (T) (Future) CompletableFuture.completedFuture(null);
|
return (T) (Future) CompletableFuture.completedFuture(null);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Laden…
In neuem Issue referenzieren
Einen Benutzer sperren