How to make client sleep in the function?

Question

I have a thread pool on the function that the clients calling.. to make only (n) clients execute this function upload() and the others wait.. i tried to call sleep() in the implementation of the function but it didn't work ... note: I'm doing this to have time to see that other clients doesn't execute the function while there are (n) clients execute it...

i need fast help please ..

the code of Server:

public class Server extends UnicastRemoteObject implements ExcutorInterface
{
public Server()throws RemoteException
{
    System.out.println("Server is in listening mode");
}

public static void main(String arg[]) throws InterruptedException
{
    try{
    LocateRegistry.createRegistry(1234);
    Server p=new Server();
    Naming.bind("//127.0.0.1:1234/obj",p);
    }catch(Exception e)
    {
    System.out.println("Exception occurred : "+e.getMessage());
    }     
}
@Override
public void executeJob()  throws RemoteException {
    System.out.println("Inside executeJob...");
    doJob a=new doJob("req_id","usrname","pwd");
    ExecutorService threadExecutor = Executors.newFixedThreadPool(2);
    threadExecutor.execute(a);
    threadExecutor.shutdown(); 
}

}

the code of doJob :

public class doJob implements Runnable {
String request_id="", usrnamee="", pswd="";
public static int i = 1;

public doJob(String request_id,String usrnamee,String pswd) {
    this.request_id=request_id;
    this.usrnamee=usrnamee;
    this.pswd=pswd;
}
public void upload() throws InterruptedException, IOException {
     Thread.sleep(1000*15);
  }
 public void run() {
            upload();
  }

}

and I call executeJob(); in the client

Answer 1

One suggestion is to make "threadExecutor" a static member variable of server. If you want only n clients then make the pool have n threads ExecutorService threadExecutor = Executors.newFixedThreadPool(n);

Shutting down within execute method id does not seem right.

The pool should be shutdown only when you decide to shutdown the server.

Till then it should be alive and process the client requests. So you have to remove the shutdown and newFixedThreadPool statements out of the executeJob method.