remove async schedule

weiboad · Oct 7, 2018 · d3b4edc · d3b4edc
1 parent 203e3b9
commit d3b4edc
Show file tree

Hide file tree

Showing 13 changed files with 3 additions and 13 deletions.
diff --git a/logpusher/pom.xml b/logpusher/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>fiery-all</artifactId>
         <groupId>com.weiboad.ragnar</groupId>
-        <version>0.5.7.3-beta</version>
+        <version>0.5.7.4-beta</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>

diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.weiboad.ragnar</groupId>
     <artifactId>fiery-all</artifactId>
-    <version>0.5.7.3-beta</version>
+    <version>0.5.7.4-beta</version>
     <packaging>pom</packaging>
 
     <name>fiery</name>

diff --git a/server/pom.xml b/server/pom.xml
@@ -5,7 +5,7 @@
     <parent>
         <artifactId>fiery-all</artifactId>
         <groupId>com.weiboad.ragnar</groupId>
-        <version>0.5.7.3-beta</version>
+        <version>0.5.7.4-beta</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>

diff --git a/server/src/main/java/org/weiboad/ragnar/server/RagnarApplication.java b/server/src/main/java/org/weiboad/ragnar/server/RagnarApplication.java
@@ -13,7 +13,6 @@
 
 @EnableScheduling
 @SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
-@EnableAsync
 public class RagnarApplication {
 
     public static void main(String[] args) {

diff --git a/server/src/main/java/org/weiboad/ragnar/server/processor/BizLogProcessor.java b/server/src/main/java/org/weiboad/ragnar/server/processor/BizLogProcessor.java
@@ -69,7 +69,6 @@ public void insertDataQueue(JsonArray data) {
         }
     }
 
-    @Async
     @Scheduled(fixedRate = 100)
     public void processData() {
 

diff --git a/server/src/main/java/org/weiboad/ragnar/server/processor/MetaLogProcessor.java b/server/src/main/java/org/weiboad/ragnar/server/processor/MetaLogProcessor.java
@@ -52,7 +52,6 @@ public boolean checkAvalible() {
         return true;
     }
 
-    @Async
     @Scheduled(fixedRate = 500)
     public void processData() {
         if (metaLogQueue == null) {

diff --git a/server/src/main/java/org/weiboad/ragnar/server/search/IndexSearchSharderManager.java b/server/src/main/java/org/weiboad/ragnar/server/search/IndexSearchSharderManager.java
@@ -222,7 +222,6 @@ private void reloadSearch() {
         }
     }
 
-    @Async
     @Scheduled(fixedRate = 5000)
     public void refreshAllIndex() {
 

diff --git a/server/src/main/java/org/weiboad/ragnar/server/search/IndexWriterShaderManager.java b/server/src/main/java/org/weiboad/ragnar/server/search/IndexWriterShaderManager.java
@@ -172,7 +172,6 @@ public boolean commitChange(String dbname) {
         return true;
     }
 
-    @Async
     @Scheduled(fixedRate = 5000)
     public void refreshIndex() {
         if (diskWriterList == null || diskWriterList.size() == 0) {

diff --git a/server/src/main/java/org/weiboad/ragnar/server/statistics/api/APIStatisticTimeSet.java b/server/src/main/java/org/weiboad/ragnar/server/statistics/api/APIStatisticTimeSet.java
@@ -256,7 +256,6 @@ public void dumpStaticDb() {
 
     }
 
-    @Async
     @Scheduled(fixedRate = 120000)
     public void cleanUpSharder() {
 

diff --git a/server/src/main/java/org/weiboad/ragnar/server/statistics/dependapi/DependAPIStatistic.java b/server/src/main/java/org/weiboad/ragnar/server/statistics/dependapi/DependAPIStatistic.java
@@ -212,7 +212,6 @@ private String getPercent(int a, int b) {
         return df.format(a * 100.00 / b) + "%";
     }
 
-    @Async
     @Scheduled(fixedRate = 30 * 1000)
     public void DelOutTimeSqlLog() {
         if (_performMap.size() > 0) {

diff --git a/server/src/main/java/org/weiboad/ragnar/server/statistics/error/ErrorStatistic.java b/server/src/main/java/org/weiboad/ragnar/server/statistics/error/ErrorStatistic.java
@@ -246,7 +246,6 @@ public boolean sendMail(String subject, String content) {
         return false;
     }
 
-    @Async
     @Scheduled(fixedRate = 30 * 1000)
     public void DelOutTimeLog() {
         if (_errorLogMap.size() > 0) {

diff --git a/server/src/main/java/org/weiboad/ragnar/server/statistics/sql/SQLStatistic.java b/server/src/main/java/org/weiboad/ragnar/server/statistics/sql/SQLStatistic.java
@@ -247,7 +247,6 @@ private String getPercent(int a, int b) {
         return df.format(a * 100.00 / b) + "%";
     }
 
-    @Async
     @Scheduled(fixedRate = 30 * 1000)
     public void DelOutTimeSqlLog() {
         if (_sqlMap!=null && _sqlMap.size() > 0) {

diff --git a/server/src/main/java/org/weiboad/ragnar/server/storage/DBManage.java b/server/src/main/java/org/weiboad/ragnar/server/storage/DBManage.java
@@ -77,7 +77,6 @@ public HashMap<String, String> getDBFolderList() {
 
 
     //remove the old db
-    @Async
     @Scheduled(fixedRate = 5000)
     public void Refresh() {