Hello Martin Sivák, Gilad Chaplik,

I'd like you to do a code review.  Please visit

    https://gerrit.ovirt.org/40912

to review the following change.

Change subject: core: Use ThreadPoolUtil instead of new Thread
......................................................................

core: Use ThreadPoolUtil instead of new Thread

use Runnable instead of new Thread. only our ThreadPoolUtil should
supply that resources and we should keep it.

Change-Id: If377e0241190d55b6d0960ff456717b3707edb34
Signed-off-by: Roy Golan <[email protected]>
---
M 
backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/SchedulingManager.java
R 
backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/external/ExternalSchedulerDiscovery.java
2 files changed, 10 insertions(+), 9 deletions(-)


  git pull ssh://gerrit.ovirt.org:29418/ovirt-engine refs/changes/12/40912/1

diff --git 
a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/SchedulingManager.java
 
b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/SchedulingManager.java
index 2141e53..89b00fa 100644
--- 
a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/SchedulingManager.java
+++ 
b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/SchedulingManager.java
@@ -19,7 +19,7 @@
 
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.lang.math.NumberUtils;
-import 
org.ovirt.engine.core.bll.scheduling.external.ExternalSchedulerDiscoveryThread;
+import 
org.ovirt.engine.core.bll.scheduling.external.ExternalSchedulerDiscovery;
 import org.ovirt.engine.core.bll.scheduling.external.ExternalSchedulerFactory;
 import org.ovirt.engine.core.common.AuditLogType;
 import org.ovirt.engine.core.common.businessentities.BusinessEntity;
@@ -46,6 +46,7 @@
 import org.ovirt.engine.core.dao.VdsGroupDAO;
 import org.ovirt.engine.core.dao.scheduling.ClusterPolicyDao;
 import org.ovirt.engine.core.dao.scheduling.PolicyUnitDao;
+import org.ovirt.engine.core.utils.threadpool.ThreadPoolUtil;
 import org.ovirt.engine.core.utils.timer.OnTimerMethodAnnotation;
 import org.ovirt.engine.core.utils.timer.SchedulerUtilQuartzImpl;
 import org.slf4j.Logger;
@@ -61,7 +62,7 @@
 
     private AuditLogDirector auditLogDirector;
     @Inject
-    private Instance<ExternalSchedulerDiscoveryThread> 
exSchedulerDiscoveryProvider;
+    private Instance<ExternalSchedulerDiscovery> exSchedulerDiscoveryProvider;
 
     private static final Logger log = 
LoggerFactory.getLogger(SchedulingManager.class);
 
@@ -99,12 +100,12 @@
         log.info("Initializing Scheduling manager");
         loadPolicyUnits();
         loadClusterPolicies();
-        ExternalSchedulerDiscoveryThread discoveryThread = 
exSchedulerDiscoveryProvider.get();
+        ExternalSchedulerDiscovery discovery = 
exSchedulerDiscoveryProvider.get();
         if (Config.<Boolean>getValue(ConfigValues.ExternalSchedulerEnabled)) {
-            log.info("Starting external scheduler discovery thread");
-            discoveryThread.start();
+            log.info("Starting external scheduler discovery");
+            ThreadPoolUtil.execute(discovery);
         } else {
-            discoveryThread.markAllExternalPoliciesAsDisabled();
+            discovery.markAllExternalPoliciesAsDisabled();
             log.info("External scheduler disabled, discovery skipped");
         }
         enableLoadBalancer();
diff --git 
a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/external/ExternalSchedulerDiscoveryThread.java
 
b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/external/ExternalSchedulerDiscovery.java
similarity index 97%
rename from 
backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/external/ExternalSchedulerDiscoveryThread.java
rename to 
backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/external/ExternalSchedulerDiscovery.java
index 314ef1f..cc64f4f 100644
--- 
a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/external/ExternalSchedulerDiscoveryThread.java
+++ 
b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/scheduling/external/ExternalSchedulerDiscovery.java
@@ -21,14 +21,14 @@
 
 import javax.inject.Inject;
 
-public class ExternalSchedulerDiscoveryThread extends Thread {
+public class ExternalSchedulerDiscovery implements Runnable {
 
     @Inject
     private SchedulingManager schedulingManager;
 
-    private final static Logger log = 
LoggerFactory.getLogger(ExternalSchedulerDiscoveryThread.class);
+    private final static Logger log = 
LoggerFactory.getLogger(ExternalSchedulerDiscovery.class);
 
-    private ExternalSchedulerDiscoveryThread() {}
+    private ExternalSchedulerDiscovery() {}
 
     @Override
     public void run() {


-- 
To view, visit https://gerrit.ovirt.org/40912
To unsubscribe, visit https://gerrit.ovirt.org/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: If377e0241190d55b6d0960ff456717b3707edb34
Gerrit-PatchSet: 1
Gerrit-Project: ovirt-engine
Gerrit-Branch: master
Gerrit-Owner: Roy Golan <[email protected]>
Gerrit-Reviewer: Gilad Chaplik <[email protected]>
Gerrit-Reviewer: Martin Sivák <[email protected]>
_______________________________________________
Engine-patches mailing list
[email protected]
http://lists.ovirt.org/mailman/listinfo/engine-patches

Reply via email to