1.3更新
- 优化代码 新增任务持久与恢复功能 任务调用和回调做为一个整体
例子:1.调用普通方法
主方法
publicstaticvoid main(String[] args){// 初始化异步工作服务AsynService anycService =AsynServiceImpl.getService(300,3000L,100,100,1000);//异步工作缓冲处理器 anycService.setWorkQueueFullHandler(newCacheAsynWorkHandler(100));//服务启动和关闭处理器 anycService.setServiceHandler(newFileAsynServiceHandler());//异步工作执行异常处理器 anycService.setErrorAsynWorkHandler(newDefaultErrorAsynWorkHandler());// 启动服务 asynService.init();// 异步回调对象AsynCallBack back =newTargetBack();for(int i =0; i <1000; i++){// 添加加异步工作- TargetService 的 test 方法 ，方法参数 asynej+ i asynService.addWork(TargetService.class,"test",newObject[]{"asyn4j"+ i },newTargetBack());//实例化目标对象再调用// TargetService targetService = new TargetService ();//asynService.addWork(// targetService , "test",new Object[] { "asyn4j" + i }, new TargetBack());}}
回调方法
//回调需继承AsynCallBack抽象类publicclassTargetBackextendsAsynCallBack{@Overridepublicvoid doNotify(){//输出异步方法调用结果System.out.println(this.methodResult);}}
目标对象
//异步调用对象publicclassTargetService{publicString test(String name){System.out.println(name +" test is execute!");return name;}}
2.调用Spring Bean的异步方法
调用 Spring testBean 的 myName 方法
applicationContext.xml 加入<bean id="springBeanUtil"class="com.googlecode.asyn4j.spring.AsynSpringUtil"></bean> <bean id="asynService" class="com.googlecode.asyn4j.spring.AsynServiceFactoryBean"> <!--设置自定义相关参数--> <property name="maxCacheWork" value="100"></property><property name="addWorkWaitTime" value="2000"></property><property name="workThreadNum" value="3"></property><property name="callbackThreadNum" value="2"></property><property name="closeServiceWaitTime" value="2000"></property><!--添加相关处理器--><property name="errorAsynWorkHandler"><bean class="com.googlecode.asyn4j.core.handler.DefaultErrorAsynWorkHandler"/></property> <property name="workQueueFullHandler"> <bean class="com.googlecode.asyn4j.core.handler.CacheAsynWorkHandler"/></property><property name="asynServiceHandler"> <bean class="com.googlecode.asyn4j.core.handler.FileAsynServiceHandler"/></property> </bean>publicclassTestMain{publicAsynService asynService;publicvoid setAsynService(AsynService asynService){this.asynService = asynService;}publicvoid maintest(){for(int i=0;i<10000;i++){ asynService.addWork("testBean","myName",newObject[]{"panxiuyan"+ i });}}}
3.相关处理器3.1异步工作缓冲器–(当工作队列工作数超过maxCacheWork时由处里器处理)
AsynService anycService =AsynServiceImpl.getService(300,3000L,100,100); anycService.setWorkQueueFullHandler(newCacheAsynWorkHandler(100)); anycService.init();
当工作队列中的工作超过300个时，异步工作将由CacheAsynWorkHandler处理;
自定义处理器 继承 WorkQueueFullHandler 抽象类
3.2服务启动和关闭处理器 –(当服务启动和关闭调用)
anycService.setCloseHander(newFileAsynServiceHandler("c:/asyn4j.data"));
设置c:/asyn4j.data为持久化文件 FileAsynServiceHandler 是 AsynServiceHandler 的一个例子将任务持久化到文件，当系统启动时加载文件内容到内存，关闭时将未执行的任务持久化到文件。大家可以参考源码将任务持久化到别外的地方（memcached）
自定义处理器 继承 AsynServiceHandler 抽象类
3.3异步工作执行异常处理器 –(当工作执行出现异常时处理器)
anycService.setErrorAsynWorkHandler(newDefaultErrorAsynWorkHandler());
自定义处理器 继承 ErrorAsynWorkHandler 抽象类
3.4所有处理器为可选配置，建议根据自己的业务继承相关的类实现自己的处理器
4.异步工作优级分成三个等级WorkWeight.LOW,WorkWeight.MIDDLE, WorkWeight.HIGH 默认优先级为WorkWeight.MIDDLE 。
API说明一.默认构造函数
AsynServiceImpl.getService();
采用的默认参数为,
- (maxCacheWork)最大工作队列缓存工作数 – 300(默认值) (addWorkWaitTime)当工作队列满时添加工作等待时间– Long.MAX_VALUE(默认值) (workThreadNum)异步工作执行线程池大小 —- CPU核数/2 +1(默认值) (callBackThreadNum)回调执行线程池大小 — CPU核数/2(默认值) (closeServiceWaitTime) 服务关闭等待时间 —- 60000s(默认值)
二.自定义参数构造函数,参数顺序对应前面的说明
AsynServiceImpl.getService (1000,1000L,3,2,60*1000);
AsynServiceImpl 是线程安全的，可以初始化一个实例，所有程序再引用.
三.设置缓存工作队列处理器（在init方法调用前设置）
publicvoid setWorkQueueFullHandler(WorkQueueFullHandler workQueueFullHandler);
系统有一个默认的处理器 CacheAsynWorkHandler 建议实现自己的处理器,需实现 addAsynWork，process 方法 。process建议启动一个守护线程监听.
四.启动服务
publicvoid init();
五．添加异步工作API
/** * 添加异步工作 * @param tagerObject -- 目标对象（可以是 Class,Object,String(spring)） * @param method -- 目标方法 */publicvoid addWork(Object tagerObject,String method);/** * 添加异步工作 * @param tagerObject －－ 目标对象（可以是 Class,Object,String(spring)） * @param method －－ 目标方法 * @param params -- 目标方法参数 */publicvoid addWork(Object tagerObject,String method,Object[]params);/** * 添加异步工作 * * * @param tagerObject －－ 目标对象（可以是 Class,Object,String(spring)） * @param method －－ 目标方法 * @param asynCallBack --回调对象 * @param params －－ 目标方法参数 */publicvoid addWork(Object tagerObject,String method,Object[]params,AsynCallBack asynCallBack);/** * 添加异步工作 * * * @param tagerObject －－ 目标对象（可以是 Class,Object,String(spring)） * @param method －－ 目标方法 * @param asynCallBack --回调对象 * @param params －－ 目标方法参数 * @param weight －－ 工作权重 */publicvoid addWork(Object tagerObject,String method,Object[]params,AsynCallBack asynCallBack,WorkWeight weight);/** * 添加异步工作 * @param tagerObject －－ 目标对象（可以是 Class,Object,String(spring)） * @param method －－ 目标方法 * @param asynCallBack --回调对象 * @param params －－ 目标方法参数 * @param weight －－ 工作权重 * @param cache －－ 如果目标对象为class，实例化后是否缓存 */publicvoid addWork(Object tagerObject,String method,Object[]params,AsynCallBack asynCallBack,WorkWeight weight,boolean cache);/** * Spring 添加异步工作 * * @param target －－ 目标对象BeanName * @param method －－ 目标方法 * @param asynCallBack --回调对象 * @param params －－ 目标方法参数 * @param weight －－ 工作权重 */publicvoid addWorkWithSpring(String target,String method,Object[]params,AsynCallBack asynCallBack,WorkWeight weight);/** * 添加异步工作 * * @param asynWork －－ 异步工作实例 */publicvoid addAsynWork(AsynWork asynWork);
六.获取运行状态信息
/** * * 获取运行状态MAP * @return */publicMap<String,Integer> getRunStatMap();Map key说明 total:累计接收异步工作数 execute:执行异步工作数 callback:执行回调数
/** * 获取运行状态字符信息 * @return */publicString getRunStatInfo();
七. 调用基于Spring Bean的异步方法
1.applicationContext.xml 加入
<beanid="springBeanUtil"class="com.googlecode.asyn4j.spring.AsynSpringUtil"></bean>
使用下列方法添加异步工作
asynService.addWork("testBean","myName",newObject[]{"asyn4j"+ i });
八．创建基于Spring 的依赖Bean
asynService spring bean 工厂
<beanid="asynService"class="com.googlecode.asyn4j.spring.AsynServiceFactoryBean"><!--设置自定义相关参数--><propertyname="maxCacheWork"value="100"></property><propertyname="addWorkWaitTime"value="2000"></property><propertyname="workThreadNum"value="3"></property><propertyname="callbackThreadNum"value="2"></property><!--添加相关处理器--><propertyname="errorAsynWorkHandler"><beanclass="com.googlecode.asyn4j.core.handler.DefaultErrorAsynWorkHandler"/></property><propertyname="workQueueFullHandler"><beanclass="com.googlecode.asyn4j.core.handler.CacheAsynWorkHandler"/></property></bean>
九.关闭服务
/** * 关闭服务等待 waitTime 秒 * @ wait time */publicvoid close(long waitTime);/** * 关闭服务等待1分钟 */publicvoid close();
十.注意
查找异步工作目标方法时,无法区分方法同名的并且参数是继承关系的方法.
一个人行走，若是寂寞了，寻一座霓虹灯迷离闪烁，
