Repo-Mirror/Leaf
9
0
Fork 0
mirror of https://github.com/Winds-Studio/Leaf.git synced 2025-12-26 02:19:19 +00:00
Code Issues Releases Activity

low freq poll

Browse Source
This commit is contained in:
hayanesuru
2025-05-26 18:41:08 +09:00
parent 59d350d50f
commit c8f0a78d75
2 changed files with 20 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
leaf-server/src/main/java/org/dreeam/leaf/async/ai/AsyncGoalExecutor.java
View File

@@ -18,7 +18,6 @@ public class AsyncGoalExecutor {
protected final SpscIntQueue queue;
protected final SpscIntQueue wake;
protected final IntArrayList submit;
private final AsyncGoalThread thread;
private final ServerLevel world;
private long midTickCount = 0L;
@@ -27,7 +26,6 @@ public class AsyncGoalExecutor {
this.queue = new SpscIntQueue(AsyncTargetFinding.queueSize);
this.wake = new SpscIntQueue(AsyncTargetFinding.queueSize);
this.submit = new IntArrayList();
this.thread = thread;
}
boolean wake(int id) {
@@ -46,7 +44,18 @@ public class AsyncGoalExecutor {
public final void tick() {
batchSubmit();
LockSupport.unpark(thread);
while (true) {
OptionalInt result = this.wake.recv();
if (result.isEmpty()) {
break;
}
int id = result.getAsInt();
if (poll(id) && !this.queue.send(id)) {
do {
wake(id);
} while (poll(id));
}
}
}
private void batchSubmit() {
@@ -67,18 +76,6 @@ public class AsyncGoalExecutor {
}
public final void midTick() {
while (true) {
OptionalInt result = this.wake.recv();
if (result.isEmpty()) {
break;
}
int id = result.getAsInt();
if (poll(id) && !this.queue.send(id)) {
do {
wake(id);
} while (poll(id));
}
}
if (AsyncTargetFinding.threshold <= 0L || (midTickCount % AsyncTargetFinding.threshold) == 0L) {
batchSubmit();
}