Excepción de estado de monitor ilegal
Cómo pasar el hilo de sondeo a otro hilo para su procesamiento. La ejecución del programa comienza en una clase de controlador que tiene un método principal y un grupo de subprocesos:
El controlador de clase principal
public static void main(String[] args) throws InterruptedException {
RunnableController controller = new RunnableController();
System.out.println(incomingQueue.size());
controller.initializeDb();
controller.initialiseThreads();
System.out.println("Polling");
controller.initialUpdate();
}
El método que tiene el hilo para la clase Polling.
private void initialiseThreads()
{
try {
threadExecutorRead = Executors.newFixedThreadPool(10);
PollingSynchronizer reader = new PollingSynchronizer(incomingQueue,dbConnection);
threadExecutorRead.submit(reader);
}catch (Exception e){
e.printStackTrace();
}
}
El método que tiene el hilo para la clase proccesor.
private void initialUpdate()
{
RunnableController.outgoingQueue = incomingQueue;
if((RunnableController.outgoingQueue)!= null){
try {
threadExecutorFetch = Executors.newFixedThreadPool(10);
MessageProcessor updater = new MessageProcessor(outgoingQueue, dbConnection);
threadExecutorFetch.submit(updater);
DBhandler dbhandler = new DBhandler();
dbhandler.updateDb(getOutgoingQueue());
} catch (Exception e) {
}
}
}
La clase Poller y la clase de controlador.
public void run() {// Thread in the Poller class
int seqId = 0;
while(true) {
List<KpiMessage> list = null;
try {
list = fullPoll(seqId);
if (!list.isEmpty()) {
seqId = list.get(0).getSequence();
incomingQueue.addAll(list);
this.outgoingQueue = incomingQueue;
System.out.println("waiting");
System.out.println("new incoming message");
while(true){
wait(3000);
notify();
}
}
} catch (Exception e1) {
e1.printStackTrace();
}
}
}
public void run() {// Second thread in the Processor Class
synchronized (this){
RunnableController.setOutgoingQueue(generate(outgoingQueue));
}
notify();
}
}
Mi tarea y pregunta es:
1.El controlador debe manejar los hilos Poller y el procesador y solo debe llamar al hilo del procesador y el poller
2.Ahora Mi pregunta es cómo hacer que el hilo del sondeador espere 3 segundos y notifique al procesador.
Me sale el error de la siguiente manera:
java.lang.IllegalMonitorStateException
at java.lang.Object.wait(Native Method)
at PollingSynchronizer.run(PollingSynchronizer.java:76)
at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
at java.util.concurrent.FutureTask$Sync.innerRun(Unknown Source)
at java.util.concurrent.FutureTask.run(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
¿Cómo lograr un procesamiento asíncrono aquí?