Springでのスレッド作成

Question

私はSpringには新しく、マルチスレッドプログラムを実装しようとしています。このリンクで春のドキュメント、https://docs.spring.io/spring/docs/3.0.x/spring-framework-reference/html/scheduling.htmlあたりとして、スレッドは次のように作成することができ、

public class TaskExecutorExample { 
    private class MessagePrinterTask implements Runnable { 
    private String message; 
    public MessagePrinterTask(String message) { 
     this.message = message; 
    } 
    public void run() { 
     System.out.println(message); 
    } 
    } 

    private TaskExecutor taskExecutor; 
    public TaskExecutorExample(TaskExecutor taskExecutor) { 
    this.taskExecutor = taskExecutor; 
    } 
    public void printMessages() { 
    for(int i = 0; i < 25; i++) { 
     taskExecutor.execute(new MessagePrinterTask("Message" + i)); 
    } 
    } 
} 

しかし、「スレッド」「新」キーワードとBeanが春で管理されていないで作成されます。したがって、Autowiredコンポーネントにはアクセスできません。この問題を回避するには、外部クラスのコンポーネントをAutowireし、コンストラクタ内のスレッドクラスに渡すことができます。

しかし、スレッドがスレッドを初期化してすべての自動配線されたコンポーネントにアクセスできるようにすることができる、これを行う他の適切な方法があります。

私が作成しているアプリケーションは、キューから受信するすべての新しいメッセージに対して新しいスレッドを作成する必要があります。

Answer 1

質問は、TaskExecutorを初期化して使用する方法に関するものとします。

<bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> 
    <property name="corePoolSize" value="5" /> 
    <property name="maxPoolSize" value="10" /> 
    <property name="queueCapacity" value="25" /> 
</bean> 

<bean id="taskExecutorExample" class="TaskExecutorExample"> 
    <constructor-arg ref="taskExecutor" /> 
</bean> 

をそれとも、その後、あなたがそれを使用することができます@Autowired

@Bean 
    public ThreadPoolTaskExecutor threadPool() { 
     ThreadPoolTaskExecutor pool = new ThreadPoolTaskExecutor(); 
     pool.setCorePoolSize(5); 
     pool.setMaxPoolSize(10); 
     pool.setQueueCapacity(25); 
     return pool; 
    } 

    @Bean 
    public TaskExecutorExample executorExample() { 
    return new TaskExecutorExample(threadPool()); 
    } 

よう@Beanを使用してコードで行うことができますので、ドキュメントはそれを行う方法を示しています。 http://www.bigsoft.co.uk/blog/index.php/2009/11/27/rules-of-a-threadpoolexecutor-pool-size

EDIT1：あなたはここに参照することができcorePoolSizeの詳細について 、maxPoolSize、queueCapacity、あなたに@Componentを追加

：後サモから明確化を持って、私はそれを更新したいと思います@Scope（ "プロトタイプ"）のスレッド。次に、あなたのスレッドを@Autowired使用し、ここでtaskExecutor.execute（sampleThread）

サンプルを実行します。https://www.mkyong.com/spring/spring-and-java-thread-example/パート：3.春のスレッドプール+春は、Bean例

・ホープこのヘルプ管理。