package alice.test.codesegment.local.wordcount;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStreamReader;
import alice.codesegment.CodeSegment;

public class SeparateArray extends CodeSegment{
	private WordConfig conf;
	
	SeparateArray(WordConfig conf){
		this.conf = conf;
	}
	
	@Override
	public void run() {	
		// cpu分だけTaskをあらかじめ作成
	 	int cpu_num = Runtime.getRuntime().availableProcessors();
	 	for (int cnt =0;cnt < cpu_num;cnt++){
	 		new WordCount();
	 	}
		BufferedReader br = null;
		int i = 0;
		try {
			br= new BufferedReader(
					new InputStreamReader(
							new FileInputStream(
									new File(conf.filename)
									)));
			int size = conf.division * 1024; // Kbyte
			Range range = new Range(size);
			int check = br.read(range.array);
			for (;check!=-1;i++){			
				char[] array;
				array = new char[size];
				check = br.read(array);
				range.nextchar = array[0];
				ods.put("array", range);
				range = new Range(array);
			} 
			new CorrectResult(i);
		} catch (FileNotFoundException e) {
			System.exit(1);
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}