1
0
AE86 3 жил өмнө
parent
commit
9377be8fa2

+ 6 - 4
dbsyncer-storage/src/main/java/org/dbsyncer/storage/lucene/Shard.java

@@ -192,10 +192,12 @@ public class Shard {
 
     private void execute(Object value, Callback callback) throws IOException {
         if (null != value) {
-            if (indexWriter.isOpen()) {
-                callback.execute();
-                indexWriter.commit();
-                return;
+            synchronized(indexWriter){
+                if (indexWriter.isOpen()) {
+                    callback.execute();
+                    indexWriter.commit();
+                    return;
+                }
             }
             logger.error(value.toString());
         }

+ 1 - 1
dbsyncer-web/src/main/resources/application.properties

@@ -4,7 +4,7 @@ server.port=18686
 #web
 dbsyncer.web.login.username=admin
 dbsyncer.web.login.password=0DPiKuNIrrVmD8IUCuw1hQxNqZc=
-dbsyncer.web.thread.pool.core.size=32
+dbsyncer.web.thread.pool.core.size=10
 dbsyncer.web.thread.pool.queue.capacity=2000
 server.servlet.session.timeout=1800
 server.servlet.context-path=/