daoas/fulddaekning/InputWorker.java

package dk.daoas.fulddaekning;

import java.util.LinkedList;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.logging.Level;
import java.util.logging.Logger;

public class InputWorker implements Runnable {
        
        static Logger logger = Logger.getLogger( InputWorker.class.toString() );
        
        Database db;
        
        public Queue<WorkSet> queue = new ConcurrentLinkedQueue<WorkSet>();
        public boolean isDone = false;
        
        
        public InputWorker(Database db) {
                this.db = db;
        }

        @Override
        public void run() {
                logger.info("Finder postnumre");
                try {

                        Queue<Integer> postnumre = new LinkedList<Integer>();
                        postnumre.addAll( db.hentPostnumre() );
                        
                        while( postnumre.isEmpty() == false) { 
                                if (queue.size() <= 25) {
                                        int postnr = postnumre.poll();

                                        WorkSet workSet = new WorkSet();
                                        workSet.postnr = postnr;
                                        
                                        BoundingBox bbox = db.getBoundingbox(postnr);
                                        bbox.validateBbox();
                                        
                                        logger.info("Bbox=" + bbox);
                                        bbox.adjustToMargin();
                                        logger.info("Bbox Adjusted=" + bbox);
                                        
                                        logger.info("Henter _ikke_ daekkede adresser i " + postnr);
                                        workSet.ikkeDaekkede = db.hentIkkedaekkedeAdresser(postnr);
                                        
                                        if ( workSet.ikkeDaekkede.isEmpty()) {
                                                //hvis der ikke er nogen adresser at arbejde på skal vi heller ikke gemme et workset
                                                logger.info("Nothing to do for " + postnr);
                                                continue;
                                        }
                                                
                                        
                                        logger.info("Henter daekkede adresser i " + postnr);
                                        workSet.daekkedeAdresser = db.hentDaekkedeAdresser(bbox);
                                                                                
                                        workSet.queueSize = workSet.ikkeDaekkede.size();
                                        
                                        queue.add(workSet);
                                } else {
                                        //queue.wait(10);
                                        Thread.sleep(10);
                                }
                        }
                        
                        logger.info("Input Worker done - stopping !!!");
                        isDone = true;
                        
                        
                } catch (Exception e) {
                        logger.log(Level.SEVERE, "Error during inputworker", e);
                        System.exit(1);
                }
                

        }

}
1	package dk.daoas.fulddaekning;
2
3	import java.util.LinkedList;
4	import java.util.Queue;
5	import java.util.concurrent.ConcurrentLinkedQueue;
6	import java.util.logging.Level;
7	import java.util.logging.Logger;
8
9	public class InputWorker implements Runnable {
10
11	static Logger logger = Logger.getLogger( InputWorker.class.toString() );
12
13	Database db;
14
15	public Queue<WorkSet> queue = new ConcurrentLinkedQueue<WorkSet>();
16	public boolean isDone = false;
17
18
19	public InputWorker(Database db) {
20	this.db = db;
21	}
22
23	@Override
24	public void run() {
25	logger.info("Finder postnumre");
26	try {
27
28	Queue<Integer> postnumre = new LinkedList<Integer>();
29	postnumre.addAll( db.hentPostnumre() );
30
31	while( postnumre.isEmpty() == false) {
32	if (queue.size() <= 25) {
33	int postnr = postnumre.poll();
34
35	WorkSet workSet = new WorkSet();
36	workSet.postnr = postnr;
37
38	BoundingBox bbox = db.getBoundingbox(postnr);
39	bbox.validateBbox();
40
41	logger.info("Bbox=" + bbox);
42	bbox.adjustToMargin();
43	logger.info("Bbox Adjusted=" + bbox);
44
45	logger.info("Henter _ikke_ daekkede adresser i " + postnr);
46	workSet.ikkeDaekkede = db.hentIkkedaekkedeAdresser(postnr);
47
48	if ( workSet.ikkeDaekkede.isEmpty()) {
49	//hvis der ikke er nogen adresser at arbejde på skal vi heller ikke gemme et workset
50	logger.info("Nothing to do for " + postnr);
51	continue;
52	}
53
54
55	logger.info("Henter daekkede adresser i " + postnr);
56	workSet.daekkedeAdresser = db.hentDaekkedeAdresser(bbox);
57
58	workSet.queueSize = workSet.ikkeDaekkede.size();
59
60	queue.add(workSet);
61	} else {
62	//queue.wait(10);
63	Thread.sleep(10);
64	}
65	}
66
67	logger.info("Input Worker done - stopping !!!");
68	isDone = true;
69
70
71	} catch (Exception e) {
72	logger.log(Level.SEVERE, "Error during inputworker", e);
73	System.exit(1);
74	}
75
76
77	}
78
79	}