/[projects]/dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java
ViewVC logotype

Diff of /dao/FuldDaekningWorker/src/dk/daoas/fulddaekning/LookupWorker.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 2718 by torben, Mon Sep 28 11:09:33 2015 UTC revision 2719 by torben, Mon Sep 28 13:32:19 2015 UTC
# Line 3  package dk.daoas.fulddaekning; Line 3  package dk.daoas.fulddaekning;
3  import java.sql.SQLException;  import java.sql.SQLException;
4  import java.util.Collection;  import java.util.Collection;
5  import java.util.Map;  import java.util.Map;
6    import java.util.NoSuchElementException;
7  import java.util.Queue;  import java.util.Queue;
8  import java.util.concurrent.BrokenBarrierException;  import java.util.concurrent.BrokenBarrierException;
9  import java.util.concurrent.CyclicBarrier;  import java.util.concurrent.CyclicBarrier;
# Line 62  public class LookupWorker implements Run Line 63  public class LookupWorker implements Run
63    
64                  while ( ! ikkeDaekkede.isEmpty() ) {                  while ( ! ikkeDaekkede.isEmpty() ) {
65                                                    
66                          Adresse qAdresse = ikkeDaekkede.remove();                          Adresse qAdresse = null;
67                            try {
68                                    qAdresse = ikkeDaekkede.remove();
69                            } catch (NoSuchElementException e) {
70                                    logger.info( "Worker/" + workerID + " NoSuchElementException");
71                                    break;
72                            }
73    
74                          short ho = qAdresse.ho;                          short ho = qAdresse.ho;
75                          KdTree<Adresse> addressTree = hoTrees.get(ho);                          KdTree<Adresse> addressTree = hoTrees.get(ho);
# Line 116  public class LookupWorker implements Run Line 123  public class LookupWorker implements Run
123                          logger.log(Level.SEVERE, e.getMessage(), e);                          logger.log(Level.SEVERE, e.getMessage(), e);
124                          System.exit(-1);                          System.exit(-1);
125                  } catch(InterruptedException e) {                  } catch(InterruptedException e) {
126                          //Do nothing                          logger.log(Level.SEVERE, e.getMessage(), e);
127                  }                  }
128    
129    
Legend:
Removed from v.2718  
changed lines
  Added in v.2719
  ViewVC Help
Powered by ViewVC 1.1.20