Main.java

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import org.common.AppLogger;
import org.processor.DataFilter;
import org.processor.FileReader;
import org.processor.FileWriter;

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
/**
 *
 * @author 404NotFound
 */
public class Main {

    static final String inputFilePath = "input.txt";
    static final String successOutputFile = "success.txt";
    static final String failedOutputFile = "failed.txt";

    public static void main(String[] args) {
        AppLogger.getInstance().setLevel(AppLogger.WARM);

        BlockingQueue<String> dataQueue = new ArrayBlockingQueue<>(1024);
        BlockingQueue<String> successOutputQueue = new ArrayBlockingQueue<>(1024, true);
        BlockingQueue<String> failedOutputQueue = new ArrayBlockingQueue<>(1024, true);

        FileReader reader = new FileReader(inputFilePath, dataQueue);
        DataFilter checker = new DataFilter(dataQueue, successOutputQueue, failedOutputQueue);
        FileWriter writeSuccessData = new FileWriter(successOutputFile, successOutputQueue);
        FileWriter writeFailedData = new FileWriter(failedOutputFile, failedOutputQueue);

        ExecutorService executor = Executors.newCachedThreadPool();
        executor.execute(reader);
        for (int i = 0; i < 100; i++) {
            executor.execute(checker);
            executor.execute(writeSuccessData);
            executor.execute(writeFailedData);
        }
        

    }
}