You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@polygene.apache.org by pa...@apache.org on 2015/07/06 18:04:42 UTC
[5/8] zest-qi4j git commit: Scheduler Library: minor code-readability
edits
Scheduler Library: minor code-readability edits
Project: http://git-wip-us.apache.org/repos/asf/zest-qi4j/repo
Commit: http://git-wip-us.apache.org/repos/asf/zest-qi4j/commit/e0be0803
Tree: http://git-wip-us.apache.org/repos/asf/zest-qi4j/tree/e0be0803
Diff: http://git-wip-us.apache.org/repos/asf/zest-qi4j/diff/e0be0803
Branch: refs/heads/develop
Commit: e0be0803dfbf530fbe1f8918082d2fca99416222
Parents: 2ba666f
Author: Paul Merlin <pa...@apache.org>
Authored: Mon Jul 6 17:35:21 2015 +0200
Committer: Paul Merlin <pa...@apache.org>
Committed: Mon Jul 6 17:35:21 2015 +0200
----------------------------------------------------------------------
.../src/main/java/org/qi4j/library/scheduler/SchedulerMixin.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/zest-qi4j/blob/e0be0803/libraries/scheduler/src/main/java/org/qi4j/library/scheduler/SchedulerMixin.java
----------------------------------------------------------------------
diff --git a/libraries/scheduler/src/main/java/org/qi4j/library/scheduler/SchedulerMixin.java b/libraries/scheduler/src/main/java/org/qi4j/library/scheduler/SchedulerMixin.java
index b4fc406..7e3b0bf 100644
--- a/libraries/scheduler/src/main/java/org/qi4j/library/scheduler/SchedulerMixin.java
+++ b/libraries/scheduler/src/main/java/org/qi4j/library/scheduler/SchedulerMixin.java
@@ -223,7 +223,7 @@ public class SchedulerMixin
// or if corePoolSize greater than workersCount.
taskExecutor = new ThreadPoolExecutor( corePoolSize, workersCount,
0, TimeUnit.MILLISECONDS,
- new LinkedBlockingQueue<>( workQueueSize ),
+ new LinkedBlockingQueue<Runnable>( workQueueSize ),
threadFactory, rejectionHandler );
taskExecutor.prestartAllCoreThreads();
managementExecutor = new ScheduledThreadPoolExecutor( 2, threadFactory, rejectionHandler );