Spring没有将bean注入线程

Question

1.如何将弹簧豆注入螺纹中

2.如何在spring bean中启动一个线程.

这是我的代码.

MyThread.java

@Component
public class MyThread implements Runnable {

    @Autowired
    ApplicationContext applicationContext;

    @Autowired
    SessionFactory sessionFactory;

    public void run() {

        while (true) {
            System.out.println("Inside run()");
            try {
                System.out.println("SessionFactory : " + sessionFactory);
            } catch (Exception e) {
                e.printStackTrace();
            }

            try {
                Thread.sleep(10000);

                System.out.println(Arrays.asList(applicationContext.getBeanDefinitionNames()));

            } catch (Exception e) {
                e.printStackTrace();
            }
        }

    }

}

我正在run从下面的类调用方法(请建议我是否遵循错误的appraoch调用spring bean中的线程)

@Component
public class MyServiceCreationListener implements ApplicationListener<ContextRefreshedEvent> {

    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {

        if (event.getApplicationContext().getParent() == null) {
            System.out.println("\nThread Started");
            Thread t = new Thread(new MyThread());
            t.start();

        }
    }
}

spring没有在MyThread类上执行依赖注入

Answer 1

您的设置存在一些问题.

1. 你不应该自己创建和管理线程,Java有很好的功能.
2. 您正在自己创建新的bean实例,并期望Spring知道它们并注入依赖项,这是行不通的.

Spring提供了一个执行任务的抽象,TaskExecutor.您应该配置一个并使用它来执行您的任务而不是自己创建一个线程.

将此添加到您的@Configuration班级.

@Bean
public ThreadPoolTaskExecutor taskExecutor() {
    return new ThreadPoolTaskExecutor();
}

你MyThread应该注明@Scope("prototype").

@Component
@Scope("prototype")
public class MyThread implements Runnable { ... }

现在你可以将这些豆子ApplicationContext注入你的MyServiceCreationListener

@Component
public class MyServiceCreationListener implements ApplicationListener<ContextRefreshedEvent> {

    @Autowired
    private ApplicationContext cox;
    @Autowired
    private TaskExecutor taskExecutor;        

    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {

        if (event.getApplicationContext().getParent() == null) {
            System.out.println("\nThread Started");
            taskExecutor.execute(ctx.getbean(MyThread.class));
        }
    }
}

这将为您提供一个预先配置的新实例,MyThread并在手边Thread选择执行它TaskExecutor.