small thread application, please help.

[Edward Chen]

I am learning Thead and therefore write a small application. Search two files and if "11111" is found, the application will stop.

Here, my questions are
1. I know this is not a good solution. Anything wrong ?

2. How to refactor it with JDK 5 Thread API ?


3. In console, why the application still outputs some log info after main thread is finished ?

4. where could I find a master-slave pattern of thread ? Any sample ?

Thanks.

public static void testThread(){
final AtomicBoolean found = new AtomicBoolean(false);
final AtomicBoolean t1Finished = new AtomicBoolean(false);
final AtomicBoolean t2Finished = new AtomicBoolean(false);
Thread t1 = new Thread(){
public void run(){
try {
System.out.println("Thread for T1 : "+Thread.currentThread().getId());
File f1 = new File("c:\\wordlist.dict1");
Scanner sc1 = new Scanner(f1);
while (sc1.hasNextLine()) {
String line = sc1.nextLine();

if(line==null) continue;
if(line.indexOf("11111")>=0 || found.get()==true) {
System.out.println("t1: found");
found.set(true);
this.interrupt();
}

}
t1Finished.set(true);
} catch (Exception e) {
System.out.print("Error: "+Thread.currentThread().getId()+" msg:"+e.getMessage());
t1Finished.set(true);
}
}
};
t1.start();

Thread t2 = new Thread(){
public void run(){
try {
System.out.println(" Thread for T2 : "+Thread.currentThread().getId());
File f2 = new File("c:\\wordlist.dict2");
Scanner sc2 = new Scanner(f2);
while (sc2.hasNextLine()) {
String line = sc2.nextLine();

if(line==null) continue;
if(line.indexOf("11111") >= 0 || found.get()==true){
System.out.println("t2: found");
found.set(true);
this.interrupt();
}
}
t2Finished.set(true);
} catch (Exception e) {
System.out.println("Error: "+Thread.currentThread().getId()+" msg:"+e.getMessage());
t2Finished.set(true);
}
}
};
t2.start();

while(true){
if(found.get()==true) break;
if(t1Finished.get()==true && t2Finished.get()==true) break;

try {
Thread.currentThread().sleep(3000);
} catch (Exception e) {
System.out.println(e.getMessage());
}

}

System.out.println("---- finished--"+found.get());
}

[ December 08, 2008: Message edited by: Edward Chen ]