潘钊 / control_service_data_Interface · Commits

Commit 208d4b016796b5f248e057fa62432697727d4bcb

Authored by 潘钊
1 parent 486ad9bf

update...

Inline Side-by-side
Showing 1 changed file with 16 additions and 2 deletions
src/main/java/com/bsth/server_rs/thread/RfidCardInfoPersistenceThread.java
  View file @208d4b0
@@ -48,10 +48,17 @@ public class RfidCardInfoPersistenceThread extends Thread{ @@ -48,10 +48,17 @@ public class RfidCardInfoPersistenceThread extends Thread{
48 */ 48 */
49 private void personCardSave(){ 49 private void personCardSave(){
50 List<Personnel> list = new ArrayList<>(); 50 List<Personnel> list = new ArrayList<>();
  51 +
  52 + Personnel p;
51 for(int i = 0; i < 1000; i ++){ 53 for(int i = 0; i < 1000; i ++){
52 - list.add(PersonBufferData.pstList.poll()); 54 + p = PersonBufferData.pstList.poll();
  55 + if(null == p)
  56 + break;
  57 + list.add(p);
53 } 58 }
54 59
  60 + if(list.size() == 0)
  61 + return;
55 final List<Personnel> finalList = list; 62 final List<Personnel> finalList = list;
56 63
57 //编程式事务 64 //编程式事务
@@ -88,10 +95,17 @@ public class RfidCardInfoPersistenceThread extends Thread{ @@ -88,10 +95,17 @@ public class RfidCardInfoPersistenceThread extends Thread{
88 */ 95 */
89 private void carCardSave(){ 96 private void carCardSave(){
90 List<Car> list = new ArrayList<>(); 97 List<Car> list = new ArrayList<>();
  98 +
  99 + Car c;
91 for(int i = 0; i < 1000; i ++){ 100 for(int i = 0; i < 1000; i ++){
92 - list.add(CarBufferData.pstList.poll()); 101 + c = CarBufferData.pstList.poll();
  102 + if(null == c)
  103 + break;
  104 + list.add(c);
93 } 105 }
94 106
  107 + if(list.size() == 0)
  108 + return;
95 final List<Car> finalList = list; 109 final List<Car> finalList = list;
96 110
97 //编程式事务 111 //编程式事务