使Spring bean的行为类似于ExecutorService的ThreadLocal实例

Question

在我的Web应用程序中，我有一个后台服务。该服务使用Generator类，该类包含Engine类，并且ExecutorService配置为使用多个线程并接受GeneratorTasks。

@Component
public class Generator {
    @Autowired
    private Engine heavyEngine;

    private ExecutorService exec = Executors.newFixedThreadPool(3);

    //I actually pass the singleton instance Generator class into the task.
    public void submitTask(TaskModel model, TaskCallback callback) {
        this.exec.submit(new GeneratorTask(model, this, callback));
    }
}

@Component
public class Engine {
    public Engine() {
        //time-consuming initialization code here
    }
}

public class GeneratorTask implements Callable<String> {
    public GeneratorTask(TaskModel m, Generator g, ReceiptCallback c) {
        this.m = m;
        this.generator = g;
        this.c = c;
    }

    public String call() throws Exception {
        //This actually calls the Engine class of the generator.
        //Maybe I should have passed the Engine itself?
        this.generator.runEngine(c);  
    }
}

Engine类需要很长时间进行初始化，因此理想情况下，我希望每个线程仅初始化一次。我不能仅仅使它成为一个单例实例，因为该实例不能在多个线程之间共享（它依赖于顺序处理）。不过，在完成处理任务之后，可以很好地重用实例。

我当时正在考虑使该private Engine heavyEngine变量成为ThreadLocal变量。但是，我也是Spring的新手，所以我想知道是否还有另一种使用Spring注释注入ThreadLocal变量的方法。我已经考虑过将bean限定在request范围内，但是我不确定在我的设计下我应该如何去做。

任何有关如何改进我的设计的指导将不胜感激。

Answer 1

首先，放弃ThreadLocal-这个班级有些可怕。您需要的只是对象池。它不是一个众所周知的功能，但是Spring也支持此功能：

<bean id="engineProto" class="Engine" scope="prototype" lazy-init="true"/>

<bean id="engine" class="org.springframework.aop.framework.ProxyFactoryBean">
    <property name="targetSource">
        <bean class="org.springframework.aop.target.CommonsPoolTargetSource">
            <property name="targetClass" value="Engine"/>
            <property name="targetBeanName" value="engineProto"/>
            <property name="maxSize" value="3"/>
            <property name="maxWait" value="5000"/>
        </bean>
    </property>
</bean>

现在，当您注入时engine，您实际上将收到代理对象（Engine将需要一个接口），该代理对象会将所有调用委派给池中的空闲对象。池大小是可配置的。当然，没有什么阻止您使用ThreadLocalTargetSource哪个使用ThreadLocal代替Commons
Pool
。两种方法均保证对线程的独占，线程安全访问Engine。

最后，您可以手动使用池化（但是上面解决方案的优点在于它是完全透明的）或切换到按定义池化的EJB。