弹簧不会将豆注入线程

Question

1.如何将弹簧豆注入线程

2.如何在弹簧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(); 

     } 
    } 
} 

春不执行依赖注入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一个预配置的，新鲜的实例并执行它在由TaskExecutor选择Thread手。

Answer 2

您的MyThread是手动创建的，而不是通过弹簧控制器文字new Thread(new MyThread());所以春天没有机会注入一个bean。

相反，您可以添加一个技巧，通过静态访问弹簧上下文，您可以从上下文获取必需的bean（请参阅here或here）。

或者，您可以使用ThreadLocal或InheritableThreadLocal来存储要在线程中使用的必需对象。

Answer 3

您正在创建Thread t = new Thread(new MyThread());.Spring容器不会注入依赖项，也不会维护bean的生命周期。

实施例：

@Component 
@Scope("prototype") 
public class PrintThread extends Thread{ 

    @Override 
    public void run() { 

     System.out.println(getName() + " is running"); 
     try { 
      Thread.sleep(5000); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
     System.out.println(getName() + " is running"); 
    } 

} 

从弹簧上下文存取线程对象。

public class ApplicationContextUtils implements ApplicationContextAware { 
private static ApplicationContext ctx; 

private static final String USER_THREAD = "printThread"; 

    @Override 
    public void setApplicationContext(ApplicationContext appContext) 
     throws BeansException { 
    ctx = appContext; 

    } 

    public static ApplicationContext getApplicationContext() { 
    return ctx; 
    } 

    public static UserService getUserService(){return ctx.getBean(USER_THREAD);} 

}