File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
core-api/src/main/java/com/optimizely/ab/odp Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -68,7 +68,13 @@ public void start() {
68
68
eventDispatcherThread = new EventDispatcherThread ();
69
69
}
70
70
if (!isRunning ) {
71
- eventDispatcherThread .start ();
71
+ final ThreadFactory threadFactory = Executors .defaultThreadFactory ();
72
+ ExecutorService executor = Executors .newSingleThreadExecutor (runnable -> {
73
+ Thread thread = threadFactory .newThread (runnable );
74
+ thread .setDaemon (true );
75
+ return thread ;
76
+ });
77
+ executor .submit (eventDispatcherThread );
72
78
}
73
79
isRunning = true ;
74
80
}
@@ -159,7 +165,7 @@ public void run() {
159
165
if (currentBatch .size () > 0 ) {
160
166
nextEvent = eventQueue .poll (nextFlushTime - new Date ().getTime (), TimeUnit .MILLISECONDS );
161
167
} else {
162
- nextEvent = eventQueue .poll ();
168
+ nextEvent = eventQueue .take ();
163
169
}
164
170
165
171
if (nextEvent == null ) {
You can’t perform that action at this time.
0 commit comments