java.util.concurrent包的并发处理.doc

浅谈java.util.concurrent包的并发处理收藏新一篇:国耻日-永远的1937年12月13日，悼念反人类的南京大屠杀七十周年我们都知道，在JDK1.5之前，Java中要进行业务并发时，通常需要有程序员独立完成代码实现，而当针对高质量Java多线程并发程序设计时,为防止死蹦等现象的出现，比如使用java之前的wait()、notify()和synchronized等，每每需要考虑性能、死锁、公平性、资源管理以及如何避免线程安全性方面带来的危害等诸多因素，往往会采用一些较为复杂的安全策略，加重了程序员的开发负担.万幸的是，在JDK1.5出现之后，Sun大神终于为我们这些可怜的小程序员推出了java.util.concurrent工具包以简化并发完成。开发者们借助于此，将有效的减少竞争条件（race conditions）和死锁线程。concurrent包很好的解决了这些问题，为我们提供了更实用的并发程序模型。java.util.concurrent下主要的接口和类：Executor：具体Runnable任务的执行者。ExecutorService:一个线程池管理者，其实现类有多种，比如普通线程池，定时调度线程池ScheduledExecutorService等，我们能把一个Runnable,Callable提交到池中让其调度。Future：是与Runnable,Callable进行交互的接口，比如一个线程执行结束后取返回的结果等等，还提供了cancel终止线程。BlockingQueue：阻塞队列。下面我写一个简单的事例程序：FutureProxy.javapackageorg.test.concurrent;/*/*Title:LoonFramework*Description:利用Future模式进行处理*Copyright:Copyright(c)2007*Company:LoonFramework*authorchenpeng*email：*version0.1*/importjava.lang.reflect.InvocationHandler;importjava.lang.reflect.Method;importjava.lang.reflect.Proxy;importjava.util.concurrent.Callable;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.Future;importjava.util.concurrent.ThreadFactory;publicabstractclassFutureProxy.privatefinalclassCallableImplimplementsCallable.publicTcall()throwsException.returnFutureProxy.this.createInstance();privatestaticclassInvocationHandlerImplimplementsInvocationHandler.privateFuturefuture;privatevolatileTinstance;InvocationHandlerImpl(Futurefuture).this.future=future;publicObjectinvoke(Objectproxy,Methodmethod,Objectargs)throwsThrowable.synchronized(this).if(this.future.isDone().this.instance=this.future.get();else.while(!this.future.isDone().try.this.instance=this.future.get();catch(InterruptedExceptione).Thread.currentThread().interrupt();returnmethod.invoke(this.instance,args);/*/*实现java.util.concurrent.ThreadFactory接口*authorchenpeng*/privatestaticfinalclassThreadFactoryImplimplementsThreadFactory.publicThreadnewThread(Runnabler).Threadthread=newThread(r);thread.setDaemon(true);returnthread;privatestaticExecutorServiceservice=Executors.newCachedThreadPool(newThreadFactoryImpl();protectedabstractTcreateInstance();protectedabstractClassgetInterface();/*/*返回代理的实例*return*/SuppressWarnings(unchecked)publicfinalTgetProxyInstance().ClassinterfaceClass=this.getInterface();if(interfaceClass=null|!interfaceClass.isInterface().thrownewIllegalStateException();Callabletask=newCallableImpl();Futurefuture=FutureProxy.service.submit(task);return(T)Proxy.newProxyInstance(interfaceClass.getClassLoader(),newCerfaceClass,newInvocationHandlerImpl(future);Test.javapackageorg.test.concurrent;importjava.util.Calendar;/*/*Title:LoonFramework*Description:*Copyright:Copyright(c)2007*Company:LoonFramework*authorchenpeng*email：*version0.1*/interfaceDateTest.StringgetDate();classDateTestImplimplementsDateTest.privateString_date=null;publicDateTestImpl().try._date+=Calendar.getInstance().getTime();/设定五秒延迟Thread.sleep(5000);catch(InterruptedExceptione).publicStringgetDate().returndate+_date;classDateTestFactoryextendsFutureProxy.OverrideprotectedDateTestcreateInstance().returnnewDateTestImpl();OverrideprotectedClassgetInterface().returnDateTest.class;publicclassTest.publicstaticvoidmain(Stringargs).DateTestFactoryfactory=newDateTestFactory();DateTestdts=newDateTest100;for(inti=0;idts.length;i+).dtsi=factory.getProxyInstance();/遍历执行for(DateTestdt:dts).System.out.println(dt.getDate();原来很麻烦的并发处理，现在轻松的得以完成