package mt_test;

import java.io.FileWriter;
import java.io.IOException;


class TTestThread extends Thread {
	public static int mValue;
	public static FileWriter mFileRes;  
	
	public void run() {
		int nValue;
		int arrRes[] = new int[100];
		while(true) {
			nValue = GetNext();
			if(nValue >= 100)
				break;
			
			for (int i = 0; i < nValue; i++) {
				arrRes[i] = i*nValue;
			}
			SaveResult(nValue, arrRes);
		}
	}
	
	synchronized void SaveResult(int nRes, int arrRes[]) {
		try {
			for (int i = 0; i < nRes; i++) {
				mFileRes.write("nRes=" + nRes + "," + arrRes[i] + "\n");
			}
			
			mFileRes.flush();
		} catch (IOException e) {
			// TODO: handle exception
		}
	}
	
	synchronized int GetNext() {
		mValue++;   
		return mValue;
	   }
	
	TTestThread(String AName) {
		super(AName);
		
		start();
	}
}

public class ClMTTest {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		TTestThread.mValue = 0;
		
		int nCores = Runtime.getRuntime().availableProcessors();
		
		TTestThread ArrThr[]  = new TTestThread[nCores];
		
		try (FileWriter FW = new FileWriter("111.txt")) {
			TTestThread.mFileRes = FW;
			
			for (int i = 0; i < ArrThr.length; i++) {
				ArrThr[i] = new TTestThread("TTestThread #" + i);
			}
			
			for (int n2 = 0; n2 < ArrThr.length; n2++) {
				ArrThr[n2].join();
			}
			
		} catch (Exception e) {
				
		}
	}
}