Есть ли в любом случае , чтобы сделать внутри него вызов класса А notify (), чтобы разбудить потоки при ожидании () блокировки этого объекта, из потока, работающего в фоне ?
спасибо.
РЕДАКТИРОВАТЬ:
Пожалуйста, игнорируйте ненужный код.Я хотел показать вам, как я на самом деле это реализовал.
Messenger - это сериализованный объект.
Поток "ServerHandler" вызовет bufferImpObject.put(<Messenger Obj>, <ServerHandler instance>, <socket instance>)
public class BufferImp {
private Messenger[] requests;
public static int req_size;
public static int req_count;
Socket s;
Messenger msg;
InputStream is;
ObjectInputStream ois;
OutputStream os;
ObjectOutputStream oos;
public BufferImp(int size) {
this.req_size = size;
this.req_count = 0;
requests = new Messenger[size];
}
class CheckWaitThread extends Thread{
Thread t;
String s;
Socket incoming_socket;
CheckWaitThread(String s, Thread t, Socket incoming_socket){
this.t = t;
this.s = s;
this.incoming_socket = incoming_socket;
}
@Override
public void run(){
try {
// I want to keep on checking till slots are FREE
// IF FREE, call notify() of BufferImp to get back WAITING (inactive) ServerHandler thread
if(t.getState().equals(State.WAITING)){
os = incoming_socket.getOutputStream();
AppendableObjectOutputStream oosa = new AppendableObjectOutputStream(os);
oosa.writeObject(new Messenger("bufferFull", null, "true"));
}
t.join();
} catch (IOException ex) {
Logger.getLogger(BufferImp.class.getName()).log(Level.SEVERE, null, ex);
} catch (InterruptedException ex) {
Logger.getLogger(BufferImp.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
// insert incoming Message objects into "requests" queue
public synchronized boolean put(Messenger o, Thread t, Socket s) throws InterruptedException {
while(req_size == req_count) {
CheckWaitThread cw = new CheckWaitThread("<----------CheckWaitThread----------->", t, s);
cw.start();
wait();
}
// these parts need to be executed when notify() is called.
requests[cur_req_in] = o;
cur_req_in = (cur_req_in + 1) % req_size;
req_count++;
notifyAll();
Messenger msg = (Messenger) o;
return true;
}
}