update...

潘钊
1 parent 3cd40e68
Showing 1 changed file with 1 additions and 24 deletions
src/main/java/com/bsth/data/gpsdata_v2/DataHandleProcess.java
@@ -75,36 +75,13 @@ public class DataHandleProcess {
  
             List<Future> fRs = new ArrayList<>(ks.size());
             for (Integer index : ks) {
-                fRs.add(threadPool.submit(new SignalHandleThread(dataListMap.get(index), count)));
+                threadPool.submit(new SignalHandleThread(dataListMap.get(index), count));
             }
  
-            //按线路分组gps
-            /*ArrayListMultimap multimap = ArrayListMultimap.create();
-            for (GpsEntity gps : list) {
-                multimap.put(gps.getLineId(), gps);
-            }
-
-            Set<String> ks = multimap.keySet();
-
-            logger.info("analyse gps size: " + list.size() + ", ks: " + ks.size());
-            count = new CountDownLatch(ks.size());
-
-            for (String lineCode : ks) {
-                threadPool.execute(new SignalHandleThread(multimap.get(lineCode), count));
-            }*/
  
             //等待子线程结束
             count.await();
  
-            for (Future f : fRs) {
-                try {
-                    f.get();
-                } catch (InterruptedException e) {
-                } catch (ExecutionException e) {
-                    logger.error(e.getCause().getMessage());
-                }
-            }
-
             //加入实时gps对照
             for (GpsEntity gps : list)
                 gpsRealData.put(gps);