package pack;
import java.util.*;
import java.io.*;
public class Fir<br> extends Thread {
private Map<String,String> map;
private BufferedReader in;
private BufferedReader br;
public Fir(){
map=new HashMap<String,String>();
}
public synchronized void stopFor(){
try{
wait(3000);
}catch(InterruptedException e){
System.out.println("Thread intrerupt");
}
}
public synchronized void nextFor(){
notify();
}
public void run(){
try{
in=new BufferedReader(new InputStreamReader(System.in));
br=new BufferedReader(new FileReader("fisier.txt"));
String line=null;
String lineUp;
synchronized (br){
while(br.ready()){
lineUp=null;
line=br.readLine();
System.out.println("Type :"+line);
br.wait(3000);
if((lineUp=in.readLine())!=null){
if(lineUp.equals(line)){
map.put(lineUp, "corect");
br.notify();
}
else{
map.put(lineUp,"gresit");
br.notify();
}
}
}
br.close();
}
}catch(IOException e){
System.out.println("Exceptie IO");
}catch(InterruptedException e){
System.out.println("Thread intrerupt");
}
}
}
package pack;
public class Test {
/**
* @param args
*/
public static void main(String[] args) {
Fir f1=new Fir();
Fir f2=new Fir();
f1.start();
//f2.start();
}
}
Niciun comentariu:
Trimiteți un comentariu