Update for release 3.3.10.

Author: mikeb01

README.md

@@ -15,9 +15,13 @@ A High Performance Inter-Thread Messaging Library
 
 ## Changelog
 
+### 3.3.10
+
+- Fix race condition in BatchEventProcessor between run() and halt().
+
 ### 3.3.9
 
-- Changle SleepingWaitStrategy to use a parkNanos(100).
+- Change SleepingWaitStrategy to use a parkNanos(100).
 
 ### 3.3.8
 

build.gradle

@@ -24,7 +24,7 @@ apply plugin: 'idea'
 defaultTasks 'build'
 
 group = 'com.lmax'
-version = new Version(major: 3, minor: 3, revision: 9)
+version = new Version(major: 3, minor: 3, revision: 10)
 
 ext {
     fullName = 'Disruptor Framework'

src/test/java/com/lmax/disruptor/BatchEventProcessorTest.java

@@ -205,7 +205,7 @@ public Object get(long sequence)
         };
 
         final LatchLifeCycleHandler h1 = new LatchLifeCycleHandler();
-        final BatchEventProcessor p1 = new BatchEventProcessor<>(dp, barrier, h1);
+        final BatchEventProcessor p1 = new BatchEventProcessor<Object>(dp, barrier, h1);
 
         Thread t1 = new Thread(p1);
         p1.halt();
@@ -217,7 +217,7 @@ public Object get(long sequence)
         for (int i = 0; i < 1000; i++)
         {
             final LatchLifeCycleHandler h2 = new LatchLifeCycleHandler();
-            final BatchEventProcessor p2 = new BatchEventProcessor<>(dp, barrier, h2);
+            final BatchEventProcessor p2 = new BatchEventProcessor<Object>(dp, barrier, h2);
             Thread t2 = new Thread(p2);
             t2.start();
             p2.halt();
@@ -229,7 +229,7 @@ public Object get(long sequence)
         for (int i = 0; i < 1000; i++)
         {
             final LatchLifeCycleHandler h2 = new LatchLifeCycleHandler();
-            final BatchEventProcessor p2 = new BatchEventProcessor<>(dp, barrier, h2);
+            final BatchEventProcessor p2 = new BatchEventProcessor<Object>(dp, barrier, h2);
             Thread t2 = new Thread(p2);
             t2.start();
             Thread.yield();