Bacteriawa
147 lines
7.8 KiB
Diff
147 lines
7.8 KiB
Diff
From 0000000000000000000000000000000000000000 Mon Sep 17 00:00:00 2001
|
|
From: Helvetica Volubi <suisuroru@blue-millennium.fun>
|
|
Date: Sat, 1 Aug 2026 16:30:53 +0800
|
|
Subject: [PATCH] Anonymous Object: RegionizedTaskQueue queue TTL optimization
|
|
|
|
As requested by the original author, this patch will be anonymous and hide the original commit address.
|
|
This patch is used with permission from the original author.
|
|
Licensed under: GPL-3.0 (https://www.gnu.org/licenses/gpl-3.0.html)
|
|
|
|
diff --git a/io/papermc/paper/threadedregions/RegionizedTaskQueue.java b/io/papermc/paper/threadedregions/RegionizedTaskQueue.java
|
|
index fe0a6bd90cba4869a0ee11723832f2dee5039f62..53579b6faa9d55485088d59ec2fd1e4251c2fb01 100644
|
|
--- a/io/papermc/paper/threadedregions/RegionizedTaskQueue.java
|
|
+++ b/io/papermc/paper/threadedregions/RegionizedTaskQueue.java
|
|
@@ -23,6 +23,7 @@ import java.util.concurrent.atomic.AtomicLong;
|
|
public final class RegionizedTaskQueue {
|
|
|
|
private static final TicketType<Long> TASK_QUEUE_TICKET = ChunkSystemTicketType.create("task_queue_ticket", Long::compareTo);
|
|
+ private static final long QUEUE_MAX_TTL_TICKS = 5L; // Anonymous - RegionizedTaskQueue queue TTL optimization
|
|
|
|
public PrioritisedExecutor.PrioritisedTask createChunkTask(final ServerLevel world, final int chunkX, final int chunkZ,
|
|
final Runnable run) {
|
|
@@ -155,6 +156,58 @@ public final class RegionizedTaskQueue {
|
|
}
|
|
}
|
|
|
|
+ // Anonymous start - RegionizedTaskQueue queue TTL optimization
|
|
+ public void tickQueueReferenceTTL() {
|
|
+ final ThreadedRegionizer.ThreadedRegion<TickRegions.TickRegionData, TickRegions.TickRegionSectionData> currentRegion
|
|
+ = io.papermc.paper.threadedregions.TickRegionScheduler.getCurrentRegion();
|
|
+ if (currentRegion == null) {
|
|
+ return;
|
|
+ }
|
|
+
|
|
+ final ReferenceCountData[] toRemoveTicket = new ReferenceCountData[1];
|
|
+
|
|
+ for (ConcurrentChainedLong2ReferenceHashTable.TableEntry<ReferenceCountData> counterEntry : this.referenceCounters.entrySet()) {
|
|
+ final long coord = counterEntry.getKey();
|
|
+ final ReferenceCountData counterData = counterEntry.getValue();
|
|
+
|
|
+ // only tick for our region
|
|
+ if (currentRegion == this.world.regioniser.getRegionAtUnsynchronised(CoordinateUtils.getChunkX(coord), CoordinateUtils.getChunkZ(coord))) {
|
|
+ long curr = counterData.referenceTTL.get();
|
|
+ // successfully decreased ttl
|
|
+ if (curr == (curr = counterData.referenceTTL.compareAndExchange(curr, curr - 1))) {
|
|
+ if (counterData.referenceCount.get() != 0L) {
|
|
+ // still has reference, pump back
|
|
+ counterData.referenceTTL.set(QUEUE_MAX_TTL_TICKS);
|
|
+ continue;
|
|
+ }
|
|
+
|
|
+ // dead
|
|
+ if (curr <= 0) {
|
|
+ // parsed from decrementReference
|
|
+ this.referenceCounters.computeIfPresent(coord, (final long keyInMap, final ReferenceCountData valueInMap) -> {
|
|
+ // might be increased again
|
|
+ if (valueInMap.referenceCount.get() != 0L) {
|
|
+ valueInMap.referenceTTL.set(QUEUE_MAX_TTL_TICKS); // still has reference, pump back
|
|
+ return valueInMap; // directly, the ttl was already charged in add logic
|
|
+ }
|
|
+
|
|
+ // note: valueInMap may not be referenceCountData
|
|
+ toRemoveTicket[0] = valueInMap;
|
|
+
|
|
+ return null;
|
|
+ });
|
|
+
|
|
+ if (toRemoveTicket[0] != null) {
|
|
+ this.removeTicket(coord, toRemoveTicket[0].id);
|
|
+ toRemoveTicket[0] = null;
|
|
+ }
|
|
+ }
|
|
+ }
|
|
+ }
|
|
+ }
|
|
+ }
|
|
+ // Anonymous end - RegionizedTaskQueue queue TTL optimization
|
|
+
|
|
private void decrementReference(final ReferenceCountData referenceCountData, final long coord) {
|
|
if (!referenceCountData.decreaseReferenceCount()) {
|
|
return;
|
|
@@ -212,9 +265,10 @@ public final class RegionizedTaskQueue {
|
|
private final long id = ID_GENERATOR.getAndIncrement();
|
|
|
|
public final AtomicLong referenceCount = new AtomicLong(1L);
|
|
+ public final AtomicLong referenceTTL = new AtomicLong(QUEUE_MAX_TTL_TICKS); // Anonymous - RegionizedTaskQueue queue TTL optimization
|
|
public volatile boolean addedTicket;
|
|
|
|
- // returns false if reference count is 0, otherwise increments ref count
|
|
+ // returns false if reference count or ttl is 0, otherwise increments ref count // Anonymous - RegionizedTaskQueue queue TTL optimization
|
|
public boolean addCount() {
|
|
int failures = 0;
|
|
for (long curr = this.referenceCount.get();;) {
|
|
@@ -227,6 +281,27 @@ public final class RegionizedTaskQueue {
|
|
}
|
|
|
|
if (curr == (curr = this.referenceCount.compareAndExchange(curr, curr + 1L))) {
|
|
+ // Anonymous start - RegionizedTaskQueue queue TTL optimization
|
|
+ // now force charge back the ttl to max
|
|
+ int ttlFailures = 0;
|
|
+ for (long currTTL = this.referenceTTL.get();;) {
|
|
+ for (int i = 0; i < ttlFailures; i++) {
|
|
+ Thread.onSpinWait();
|
|
+ }
|
|
+
|
|
+ // add failed, rollback (ttl reached)
|
|
+ if (currTTL <= 0) {
|
|
+ this.referenceCount.decrementAndGet(); // revert the addition
|
|
+ return false;
|
|
+ }
|
|
+
|
|
+ if (currTTL == (currTTL = this.referenceTTL.compareAndExchange(currTTL, QUEUE_MAX_TTL_TICKS))) {
|
|
+ break;
|
|
+ }
|
|
+
|
|
+ ++ttlFailures;
|
|
+ }
|
|
+ // Anonymous end - RegionizedTaskQueue queue TTL optimization
|
|
return true;
|
|
}
|
|
|
|
@@ -234,11 +309,11 @@ public final class RegionizedTaskQueue {
|
|
}
|
|
}
|
|
|
|
- // returns true if new reference count is 0
|
|
+ // returns true if new reference count and ttl is 0 // Anonymous - RegionizedTaskQueue queue TTL optimization
|
|
public boolean decreaseReferenceCount() {
|
|
final long res = this.referenceCount.decrementAndGet();
|
|
if (res >= 0L) {
|
|
- return res == 0L;
|
|
+ return res == 0L && this.referenceTTL.get() <= 0L; // Anonymous - RegionizedTaskQueue queue TTL optimization
|
|
} else {
|
|
throw new IllegalStateException("Negative reference count");
|
|
}
|
|
diff --git a/net/minecraft/server/MinecraftServer.java b/net/minecraft/server/MinecraftServer.java
|
|
index 657801b605ff49af0a7b80e17bc45b89e243b35e..b498cecb37cf83d31ad4a02bb1acecf7328e7aa6 100644
|
|
--- a/net/minecraft/server/MinecraftServer.java
|
|
+++ b/net/minecraft/server/MinecraftServer.java
|
|
@@ -1755,6 +1755,7 @@ public abstract class MinecraftServer extends ReentrantBlockableEventLoop<TickTa
|
|
foliaProfiler.stopTimer(ca.spottedleaf.leafprofiler.LProfilerRegistry.PASSENGER_DESYNC_CHECK);
|
|
}
|
|
// Folia end - fix passenger desync
|
|
+ region.world.taskQueueRegionData.tickQueueReferenceTTL(); // Anonymous - RegionizedTaskQueue queue TTL optimization
|
|
}
|
|
// Folia end - region threading
|
|
//this.tickCount++; // Folia - region threading
|