@Configuration
@SpringBootApplication
@Import({ThreadConfig.class})
public class ThreadApp implements CommandLineRunner
{
 public static void main(String[] args) throws Exception {

  ApplicationContext app = SpringApplication.run(ThreadApp .class, args);
  //這里主要保存上下文對象實例，需要加上。SpringBootUtils類網(wǎng)上很多，可以自己搜下
  SpringBootUtils.setApplicationContext(app);

 }

 //access command line arguments
 @Override
 public void run(String... args) throws Exception {
  //do something
 }
}

//ComponentScan注解會掃描com.demo.thead下，也就是多線程類所在的包下的文件
@Configuration
@ComponentScan(basePackages = { "com.demo.thread"})
public class ThreadConfig{

}

@Component
public class demoThread extends Thread
{
 //注意這里，如果你沒有實現(xiàn)把多線程類的實例注入到spring容器中，這里你是無法拿到其他自動裝配的對象實例的的，這也是我們第一步的意義所在。
 @Autowired
 private XxxService xxxService;

 @PostConstruct
 public void start() {
  super.start();
 }

 public void run() {
  // Ok,在這里你就可以實現(xiàn)線程要實現(xiàn)的功能邏輯了，自然也可以直接使用裝配好的sevice對象實例。
  
 }
}

private TaskThread thread;
 private ExecutorService taskPool= new ThreadPoolExecutor(
   5, 10, 1000,
   TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(10),
   new ThreadPoolExecutor.CallerRunsPolicy()); 


 @KafkaListener(topics = "xxTopic")
 public void receive(ConsumerRecord<Object, Object> consumerRecord) {
   JSONObject json = JSON.parseObject(consumerRecord.value().toString());
   //通過SpringBootUtils獲取線程類的實例
   thread = SpringBootUtils.getBean(TaskThread.class);
   //啟動線程
   //new Thread(thread).start() ; 
   //向線程對象里傳值
   thread.init(i);
   //放入線程池執(zhí)行
   taskPool.execute(thread);

 }

//注意這里是否添加@Scope("prototype")注解
@Component
@Scope("prototype")
public class TaskThread implements Runnable{
 
 protected int value=0；

 @Autowired
 private XxxService xxxService;
 
 //ThreadLocal 對象，單例模式下可以保證成員變量的線程安全和獨立性。
 public ThreadLocal<Integer> valueLocal = new ThreadLocal < Integer > () {
  @Override
  protected Integer initialValue() {
   return 0;
  }
 };

 protected static final Logger LOG = LoggerFactory.getLogger(GpsTaskThread.class);
 
 @Override
 public final void run() {
  try { 
   LOG.info(value+"");
   
  } catch (Exception e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }
 }

 public void init(int Value) {
  this.value=Value;
 }
}