资 源 简 介
What is ParaJ
ParaJ is set of parallel algorithms simplifying creation of multi-threaded programs.
Example usage of Feed Engine
```
public void convert(InputStream in, OutputStream out) {
CsvReader reader = initializeReader(in);
FeedEngine engine = new FeedEngine();
engine.setMaxErrorCount(10);
engine.addProducer(new CsvRecordReader(reader));
engine.addConsumer(new Transformer());
engine.addConsumer(new Transformer());
engine.addConsumer(new Transformer());
engine.runUntilAllProcessed();
logErrors(engine.getErrors());
writeToOutputStream(out, records);
}
```
CvsRecordReader
```
private static class CsvRecordReader implements Producer {
private final CsvReader reader;
public CsvRecordReader(CsvReader reader) {
this.reader = reader;
}
public String[] produce() throws Exception {
if (!reader.readRecord()