Skip to content

Commit

Permalink
Refactor signaler class name (#1111)
Browse files Browse the repository at this point in the history
  • Loading branch information
jfallows authored Jun 27, 2024
1 parent d96b9f6 commit 36239d2
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -206,7 +206,7 @@ public class EngineWorker implements EngineContext, Agent
private final DeadlineTimerWheel timerWheel;
private final Long2ObjectHashMap<Runnable> tasksByTimerId;
private final Long2ObjectHashMap<Future<?>> futuresById;
private final ElektronSignaler signaler;
private final EngineSignaler signaler;
private final Long2ObjectHashMap<MessageConsumer> correlations;
private final Long2ObjectHashMap<AgentRunner> exportersById;
private final Map<String, ModelContext> modelsByType;
Expand Down Expand Up @@ -339,7 +339,7 @@ public EngineWorker(
this.timerWheel = new DeadlineTimerWheel(MILLISECONDS, currentTimeMillis(), 512, 1024);
this.tasksByTimerId = new Long2ObjectHashMap<>();
this.futuresById = new Long2ObjectHashMap<>();
this.signaler = new ElektronSignaler(executor, Math.max(config.bufferSlotCapacity(), 512));
this.signaler = new EngineSignaler(executor, Math.max(config.bufferSlotCapacity(), 512));

this.poller = new Poller();

Expand Down Expand Up @@ -1902,15 +1902,15 @@ private Int2ObjectHashMap<MessageConsumer>[] initDispatcher()
return dispatcher;
}

private final class ElektronSignaler implements Signaler
private final class EngineSignaler implements Signaler
{
private final ThreadLocal<SignalFW.Builder> signalRW;

private final ExecutorService executorService;

private long nextFutureId;

private ElektronSignaler(
private EngineSignaler(
ExecutorService executorService,
int slotCapacity)
{
Expand Down

0 comments on commit 36239d2

Please sign in to comment.