如何将轮询线程传递给另一个线程进行处理。程序执行在具有主方法和线程池的控制器类中:
主类控制器
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(); }
具有轮询类的线程的方法
private void initialiseThreads() { try { threadExecutorRead = Executors.newFixedThreadPool(10); PollingSynchronizer reader = new PollingSynchronizer(incomingQueue,dbConnection); threadExecutorRead.submit(reader); }catch (Exception e){ e.printStackTrace(); } }
具有proc类的线程的方法
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) { } } }
轮询类和控制器类
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(); } }
我的任务和问题是:
1.控制器应同时处理轮询器和处理器线程,并且应仅调用轮询器和处理器线程
2.现在我的问题是如何使轮询线程等待3秒并并行通知处理器。
我得到如下错误:
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)
这里如何实现异步处理?
你需要阅读的东西像这样第一。您必须wait()握住对象的监视器才能使用。而且,从一眼就可以看出,您似乎在多线程上下文中使用了非最终静态成员。尝试使该线程安全。
wait()