1 2 3 4 5 6 7 8 9 10 11 12 | … //create threads synchronized(workThreadVector) { for(int j = 0; j < i; j++) { threadNum++; WorkThread workThread = new WorkThread(taskVector, threadNum); workThreadVector.addElement(workThread); } } … |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 | … while(!workThreadVector.isEmpty()) { if(debugLevel > 2) System.out.println("stop:"+(i)); i++; try { WorkThread workThread = (WorkThread)workThreadVector.remove(0); workThread.closeThread(); continue; } catch(Exception exception) { if(debugLevel > 2) exception.printStackTrace(); } break; } … |
1 2 3 4 5 6 7 | … synchronized(taskVector) { taskVector.addElement(taskObj); taskVector.notifyAll(); } … |
欢迎光临 电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/) | Powered by Discuz! 7.0.0 |