Java程序框架--多线程异步处理多任务

package taskCenter; import java.util.ArrayList; import java.util.Stack; public class TaskProcesserFactory { static private TaskProcesserFactory factory = new TaskProcesserFactory(); private Stack processers = new Stack(); private ArrayList total_Processers = new ArrayList(); private int currProcessers = 0; /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub } public void process(Task t) { TaskProcesser employee = getProcesser(); if(employee != null) employee.assignTask(t); } private TaskProcesserFactory() { for(;currProcessers<ApplicationConstant.MIN_PROCESSERS;currProcessers++) { TaskProcesser p = new TaskProcesser("Thread-"+ (currProcessers+1), this); p.start(); addFactory(p); total_Processers.add(p); } } public TaskProcesser getProcesser() { TaskProcesser p = null; try { p =(TaskProcesser)processers.pop(); return p; } catch(Exception e) { p = newProcesser(); return p; } } public void removeProcessor(TaskProcesser p) { processers.remove(p); } public boolean isAvaible() { boolean result = !processers.isEmpty(); if(!result) { result = !(currProcessers == ApplicationConstant.MAX_PROCESSERS); } if(!result) System.out.println("Task Processer no extro processor"); return result; } private synchronized TaskProcesser newProcesser() { if(currProcessers < ApplicationConstant.MAX_PROCESSERS) { TaskProcesser p = new TaskProcesser("Thread-"+ (currProcessers+1),this); p.start(); addFactory(p); total_Processers.add(p); currProcessers++; //processers.push(p); return p; } return null; } public void addFactory(TaskProcesser newProcessor) { processers.push(newProcessor); } static public TaskProcesserFactory getInstance() { return factory; } public void close() { System.out.println(total_Processers.size()); for(int i = 0; i< total_Processers.size(); i++) { TaskProcesser p = (TaskProcesser)total_Processers.get(i); p.interrupt(); //p.notify(); System.out.println("Interupt :" + p); } try { notifyAll(); } catch(Exception e) { ; } } }