7 |
import java.util.concurrent.CyclicBarrier; |
import java.util.concurrent.CyclicBarrier; |
8 |
import java.util.concurrent.atomic.AtomicInteger; |
import java.util.concurrent.atomic.AtomicInteger; |
9 |
import java.util.logging.Level; |
import java.util.logging.Level; |
|
import java.util.logging.Logger; |
|
10 |
|
|
11 |
import ags.utils.dataStructures.MaxHeap; |
import ags.utils.dataStructures.MaxHeap; |
12 |
import ags.utils.dataStructures.trees.thirdGenKD.DistanceFunction; |
import ags.utils.dataStructures.trees.thirdGenKD.DistanceFunction; |
15 |
import dk.daoas.adressevedligehold.ServiceConfig; |
import dk.daoas.adressevedligehold.ServiceConfig; |
16 |
import dk.daoas.adressevedligehold.beans.Address; |
import dk.daoas.adressevedligehold.beans.Address; |
17 |
import dk.daoas.adressevedligehold.tasks.Task; |
import dk.daoas.adressevedligehold.tasks.Task; |
18 |
|
import dk.daoas.adressevedligehold.tasks.TaskLogger; |
19 |
|
|
20 |
public class LookupWorker implements Runnable { |
public class LookupWorker implements Runnable { |
21 |
|
|
22 |
static final int MAX_RESULTS = 99; |
static final int MAX_RESULTS = 99; |
23 |
|
|
24 |
|
|
25 |
final static Logger logger = Logger.getLogger( LookupWorker.class.toString() ); |
private TaskLogger logger = TaskLogger.getInstance(); |
26 |
|
|
27 |
OSRMHelper osrmHelper = new OSRMHelper(); |
OSRMHelper osrmHelper = new OSRMHelper(); |
28 |
|
|
135 |
try { |
try { |
136 |
db.gemResultat(qAddress, bedsteAdr, bedsteAfstand); |
db.gemResultat(qAddress, bedsteAdr, bedsteAfstand); |
137 |
} catch (SQLException e) { |
} catch (SQLException e) { |
138 |
logger.log(Level.WARNING, "Error saving result", e); |
logger.warning("Error saving result", e); |
139 |
logger.warning("Shutting down"); |
logger.warning("Shutting down"); |
140 |
throw e; // rethrow |
throw e; // rethrow |
141 |
} |
} |