/**

 *

 * Copyright (c) 1995-2009 Wonders Information Co.,Ltd.

 * 1518 Lianhang Rd,Shanghai 201112.P.R.C.

 * All Rights Reserved.

 *

 * This software is the confidential and proprietary information of Wonders Group.

 * (Social Security Department). You shall not disclose such

 * Confidential Information and shall use it only in accordance with

 * the terms of the license agreement you entered into with Wonders Group.

 *

 * Distributable under GNU LGPL license by gnu.org

 */

package com.yundaex.common.parent.threadpool;

import org.springframework.beans.BeansException;

import org.springframework.context.ApplicationContext;

import org.springframework.context.ApplicationContextAware;

import org.springframework.stereotype.Repository;

/**

 * <p>

 * Title: Adage_[子系统统名]_[模块名]

 * </p>

 * <p>

 * Description: 并发任务工厂,用于动态获取并发任务实例

 * 注意：主要用于事务包装的并发任务，在用SPRING包装任务的事务时，需要注意，任务bean和任务代理bean必须均为Prototype类型(singleton为false)

 * </p>

 *

 * @author Jessy

 * @version $Revision$ 2010-8-4

 * @author (lastest modification by $Author$)

 * @since 1.0

 */

@Repository("taskFactory")

public final class TaskFactory implements ApplicationContextAware {

    private ApplicationContext applicationContext;

    private static TaskFactory instance;

    private TaskFactory() {

    }

    /**

     * <p>

     * Discription:获取任务工厂实例

     * </p>

     *

     * @return

     */

    public static TaskFactory getInstance() {

        if (instance == null) {

            instance = new TaskFactory();

        }

        return instance;

    }

    /**

     * <p>

     * Discription:创建并发任务

     * </p>

     *

     * @param <T> 泛型

     * @param type 任务类型

     * @param taskClass 任务CLASS

     * @return

     */

    public <T extends Task> T createTask(String type, Class<T> taskClass) {

        return taskClass.cast(applicationContext.getBean(type));

    }

    /**

     * {@inheritDoc}

     *

     * @see org.springframework.context.ApplicationContextAware#

     *      setApplicationContext(org.springframework.context.ApplicationContext)

     */

    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {

        this.applicationContext = applicationContext;

    }

}

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"

"http://www.springframework.org/dtd/spring-beans.dtd">

<beans>

    <description></description>

    <bean id="simpleThreadPool" class="com.yundaex.common.parent.threadpool.runtime.SimpleThreadPool"

        abstract="true">

    </bean>

    <bean id="dynamicThreadPool" class="com.yundaex.common.parent.threadpool.runtime.DynamicThreadPool"

        abstract="true">

        <!--<property name="maxSize" value="${your.module.maxSize}"></property>

        <property name="minSize" value="${your.module.minSize}"></property>

        <property name="checkPeriod" value="${your.module.checkPeriod}"></property>

        <property name="sparePeriod" value="${your.module.sparePeriod}"></property>-->

    </bean>

    <bean id="taskFactory" class="com.yundaex.common.parent.threadpool.TaskFactory"

        factory-method="getInstance">

    </bean>

</beans>