Commit 5f6f377e608bbc9b0e013c7eb77de1268f0a3c1d
Exists in
master
and in
6 other branches
Merge remote-tracking branch 'origin/master'
Showing 1 changed file
platform-operate-api/src/main/java/com/lyms/platform/operate/web/utils/SendMysqlSyncDatUtil.java
View file @
5f6f377
| ... | ... | @@ -51,7 +51,7 @@ |
| 51 | 51 | request.setSql(Base64.encodeBase64String(sql.getBytes())); |
| 52 | 52 | request.setSqlId(sqlId); |
| 53 | 53 | syncSqlQueue.add(request); |
| 54 | - System.out.println("syncSqlQueue size = " + syncSqlQueue.size()); | |
| 54 | + System.out.println("syncSqlQueue size = " + syncSqlQueue.size()); | |
| 55 | 55 | } |
| 56 | 56 | |
| 57 | 57 | /** |
| ... | ... | @@ -77,7 +77,9 @@ |
| 77 | 77 | SqlRequest request = null; |
| 78 | 78 | while (true) { |
| 79 | 79 | try { |
| 80 | - request = syncSqlQueue.poll(); | |
| 80 | + Thread.sleep(3000); | |
| 81 | + request = syncSqlQueue.take(); | |
| 82 | + System.out.println(request); | |
| 81 | 83 | String json = JsonUtil.obj2Str(request); |
| 82 | 84 | if (CollectionUtils.isNotEmpty(urls)) |
| 83 | 85 | { |