Revision 53685
Added by Giorgos Papanikos over 5 years ago
KaggleRepositoryIterable.java | ||
---|---|---|
117 | 117 |
public void bootstrap() { |
118 | 118 |
this.queue = new ArrayBlockingQueue<>(this.options.getQueueSize()); |
119 | 119 |
|
120 |
ExecutorService executor = Executors.newSingleThreadExecutor(); |
|
121 |
executor.execute(new Harvester()); |
|
122 |
executor.shutdown(); |
|
120 |
Thread ft = new Thread(new Harvester() ); |
|
121 |
ft.start(); |
|
122 |
// ExecutorService executor = Executors.newSingleThreadExecutor(); |
|
123 |
// executor.execute(new Harvester()); |
|
124 |
// executor.shutdown(); |
|
123 | 125 |
} |
124 | 126 |
|
125 | 127 |
@Override |
Also available in: Unified diff
Added safeguard parsing of produced xml to catch badly escaped illegal characters (eg etf: \001 escaped as ). Changed harvesting thread execution from ThreadExecutor to Thread.Start