x

src/main/java/com/egolm/pds/config/ScheduleConfig.java

+package com.egolm.pds.config;
+
+import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.ThreadFactory;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
+
+@Configuration
+
+public class ScheduleConfig implements SchedulingConfigurer {
+
+	public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
+	
+		scheduledTaskRegistrar.setScheduler(new ScheduledThreadPoolExecutor(Runtime.getRuntime().availableProcessors(), new ThreadFactory() {
+			public Thread newThread(Runnable r) {
+				return new Thread(r,"my-schedule");
+			}
+		}));
+	
+	}
+
+}

src/main/java/com/egolm/pds/schedule/ProductsTask.java

@@ -49,15 +49,12 @@ public class ProductsTask {
 	private void executeUpdateTask() {
 		Map<String, String> headers = new HashMap<String, String>();
 		headers.put(authKey, authValue);
-		
-		
-		boolean isFinishd = false;
-		while(!isFinishd) {
+		while(true) {
 			String responseBody = HttpUtil.get(urlQuery, headers);
 			JSONObject jsonObject = JSON.parseObject(responseBody);
 			JSONArray jsonArray = jsonObject.getJSONArray("data");
 			if(jsonArray == null || jsonArray.size() == 0) {
-				isFinishd = true;
+				break;
 			} else {
 				for(int i = 0; i < jsonArray.size(); i++) {
 					JSONObject productJsonObject = jsonArray.getJSONObject(i);