mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-07-04 15:27:30 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added support for pooling UpdateSequence instances to allow asynchronous sequencing

Browse Source
This commit is contained in:
Collin Smith
2020-09-07 01:28:19 -07:00
parent aadc9d2de8
commit f215a7f191
2 changed files with 18 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/com/riiablo/attributes/AttributesUpdater.java
View File

@ -9,8 +9,6 @@ import com.riiablo.logger.MDC;
public final class AttributesUpdater {
private static final Logger log = LogManager.getLogger(AttributesUpdater.class);
private final UpdateSequence SEQUENCER = new UpdateSequence(this);
public UpdateSequence update(final Attributes attrs, final CharStats.Entry charStats) {
return update(attrs, attrs, charStats);
}
@ -27,7 +25,7 @@ public final class AttributesUpdater {
final int listFlags,
final Attributes opBase,
final CharStats.Entry charStats) {
return SEQUENCER.reset(attrs, listFlags, opBase, charStats);
return UpdateSequence.obtain().reset(this, attrs, listFlags, opBase, charStats);
}
void add(

26
core/src/com/riiablo/attributes/UpdateSequence.java
View File

@ -2,6 +2,9 @@ package com.riiablo.attributes;
import java.util.Arrays;
import com.badlogic.gdx.utils.Pool;
import com.badlogic.gdx.utils.Pools;
import com.riiablo.codec.excel.CharStats;
import com.riiablo.logger.LogManager;
import com.riiablo.logger.Logger;
@ -9,10 +12,15 @@ import com.riiablo.logger.Logger;
public class UpdateSequence {
private static final Logger log = LogManager.getLogger(UpdateSequence.class);
private static final Pool<UpdateSequence> POOL = Pools.get(UpdateSequence.class, 16);
static UpdateSequence obtain() {
return POOL.obtain();
}
private static final int MAX_SEQUENCE_LENGTH = 32;
private final StatListGetter[] sequence = new StatListGetter[MAX_SEQUENCE_LENGTH];
private final AttributesUpdater updater;
private AttributesUpdater updater;
private int sequenceLength;
private boolean sequencing;
@ -20,10 +28,6 @@ public class UpdateSequence {
private Attributes opBase;
private CharStats.Entry charStats;
UpdateSequence(final AttributesUpdater updater) {
this.updater = updater;
}
public Attributes apply() {
final StatListGetter[] sequence = this.sequence;
for (int i = 0; i < sequenceLength; i++) {
@ -32,10 +36,14 @@ public class UpdateSequence {
}
updater.apply(attrs, charStats, opBase);
return clear();
final Attributes attrs = this.attrs;
clear();
POOL.free(this);
return attrs;
}
UpdateSequence reset(
final AttributesUpdater updater,
final Attributes attrs,
final int listFlags,
final Attributes opBase,
@ -44,20 +52,20 @@ public class UpdateSequence {
throw new IllegalStateException("sequence locked, must apply current sequence");
}
this.updater = updater;
this.attrs = attrs.reset();
this.opBase = opBase;
this.charStats = charStats;
return addAll(attrs, listFlags);
}
Attributes clear() {
void clear() {
sequencing = false;
Arrays.fill(sequence, 0, sequenceLength, null);
sequenceLength = 0;
final Attributes attrs = this.attrs;
this.attrs = null;
this.charStats = null;
return attrs;
this.updater = null;
}
public UpdateSequence add(StatListGetter stats) {