We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7056fc1 commit 1d7fe50Copy full SHA for 1d7fe50
src/main/java/com/lmax/disruptor/BatchEventProcessor.java
@@ -120,6 +120,7 @@ public void run()
120
notifyStart();
121
try
122
{
123
+
124
if (running.get() == RUNNING)
125
126
processEvents();
@@ -193,14 +194,8 @@ private void processEvents()
193
194
195
private void earlyExit()
196
- try
197
- {
198
- notifyStart();
199
- }
200
- finally
201
202
- notifyShutdown();
203
+ notifyStart();
+ notifyShutdown();
204
}
205
206
private void notifyTimeout(final long availableSequence)
0 commit comments