change
This commit is contained in:
parent
c8cceb68d3
commit
97a2838324
|
@ -56,9 +56,7 @@ public class SubTableService extends AbstractService {
|
||||||
ExecutorService executor = Executors.newFixedThreadPool(threadSize);
|
ExecutorService executor = Executors.newFixedThreadPool(threadSize);
|
||||||
Future<Integer> future = executor.submit(() -> insert(subTableValues));
|
Future<Integer> future = executor.submit(() -> insert(subTableValues));
|
||||||
executor.shutdown();
|
executor.shutdown();
|
||||||
|
//TODO:frequency
|
||||||
//TODO:
|
|
||||||
sleep(1000);
|
|
||||||
return getAffectRows(future);
|
return getAffectRows(future);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -67,7 +65,6 @@ public class SubTableService extends AbstractService {
|
||||||
ExecutorService executor = Executors.newFixedThreadPool(threadSize);
|
ExecutorService executor = Executors.newFixedThreadPool(threadSize);
|
||||||
Future<Integer> future = executor.submit(() -> insertAutoCreateTable(subTableValues));
|
Future<Integer> future = executor.submit(() -> insertAutoCreateTable(subTableValues));
|
||||||
executor.shutdown();
|
executor.shutdown();
|
||||||
|
|
||||||
return getAffectRows(future);
|
return getAffectRows(future);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue