[mohit]

Hello everyone,

please see the below code first

package com.test;
class DemoAlive extends Thread {
 
    int value;
 
    public DemoAlive(String str)
    {
        super(str); 
        value=0;
        start();    
    }
 
 
     public void run()
     {
    
        try
     {
            while (value < 5) {
              
      System.out.println(getName() + ": " + (value++));
      test(getName());
                Thread.sleep(250);  
            }
        } catch (Exception e) {}
 
        System.out.println("Exit from thread: " + getName());
    }
     
     public void test(String str){
          System.out.println(str +": testing threading");
     }
}
 
package com.test;
 
import java.io.File;
 
public class threadimpl {
public static void main(String[] args) {
        // TODO Auto-generated method stub
        threadimpl obj=new threadimpl();
        obj.listDirectory(new File("D:\\Sample"));
    }
    
    private void listDirectory(File path){
        if(path.isDirectory()){
            String[] listDir=path.list();
            for(int dirCount=0; dirCount<listDir.length;dirCount++){
                File filePath=new File(listDir[dirCount]);
                if(filePath.isDirectory()){
                    listDirectory(filePath);
                }else{
                    processFile(filePath);
                }
            }
        }else{
            processFile(path);
        }
    }
    
    private void processFile(File datFile){
        DemoAlive obj= new DemoAlive(datFile.getName());
    }
} 

this is working properly but now i want to create threads for first 5 file when one thread complete then another thread for new file should start.

example. i have 10 files. this code should process first 5 file then when any file complete the process then 6th file should enter for processing.

any help.

Thanks,

[UnrealEd]

There's really no point in doing it like that: You keep adding a new File object to your DemoAlive class, when you can easily pass on all data. If you want to do it your way, you will have to create a new class, also threaded, to check what the current value of the DemoAlive threaded class is, and, if value=4, add a new File object. This way you will overcomplicate such a simple task.

Can you explain a little more what you're trying to do? Maybe I can give you some advice on using threads (or maybe not ).

At first sight it seems lke you're about to process files, correct? And instead of waiting till 1 File is processed so you can proceed the scanning, you want to do it all at once, right?
If this all is true, I'd use a Queue (FIFO=first in-first out) to store all File objects you found during the scanning of a directory. You store the Queue (different link than the one above) in a threaded class, suchas your DemoAlive class, and keep appending files to it while you scan. There's probably a limit to the size of the Queue, so you might have to create several instances of the DemoAlive class, and spread the scanned File objects over the threads. There's no point on "updating" the Queue in one of the existing threads, just leave the thread to die once it has processed its Queue.

[mohit]

yes .. you are bit close but i di it in different way see the code

private void processFile(File datFile){
        
        DemoAlive obj= new DemoAlive(datFile.getName(), count++);
        try{
            while (Thread.activeCount()>5) {
                 System.out.println("Sleeping: " + obj.getName());                  
                 obj.join();
            } 
         }catch(Exception ex){
           
         }
        
    } 

it is working for me.
it create 5 threads the it wait to finish first five thread then after finishing all first 5 threads then it create next 5 threads.

but actually i wanted that one thread complete among 5 threads i could start 6th one.

please let me know how can i do that.

see my plan is that.
i have created a list of files from system.
i need to scan all files and one thread should scan one file and so on.
and also 5 thread should only be active at a time.

Please suggest me.

Thanks