[email protected] 和 @Async一起使用做非同步

首先建立一個類我叫他Jeep

package com.gcx.spring.z_springboot_Enablexxx;

import java.util.concurrent.TimeUnit;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

@Component
public class Jeep implements Runnable{

	public void run() {
		for(int i=0;i<10;i++) {
			try {
				System.out.println("=================:"+i);
				TimeUnit.SECONDS.sleep(1);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}

}
 

然後我們在Maven預設的App.class中呼叫

package com.gcx.spring.z_springboot_Enablexxx;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.scheduling.annotation.EnableAsync;

/**
 * Hello world!
 *EnableAsync 和@Async一起使用
 *@Import 匯入一個活著的多個配置類 會被spring容器所託管 ，如果匯入配置類,配置類所有bean都會被spring容器託管
 */
@SpringBootApplication
public class App {
    public static void main( String[] args ){
    	ConfigurableApplicationContext context = SpringApplication.run(App.class, args);
    	context.getBean(Runnable.class).run();
    	System.out.println("===end=====");
    	context.close();
    
    }
}
 

現在的情況是沒有非同步的情況，只能等待run方法執行之後再列印 end

接下來我們使用非同步情況

在App.class加上 @EnableAsync註解。在Jeep.class上的run方法，加上@Async註解，列印結果如下

發現結果的確是非同步執行的

2.我們來看看Enable註解內部的原理，發現裡面都有@Import註解，它其實就是匯入一個類，舉例說明

建立一個User.class，Role.class

package com.gcx.spring.z_springboot_Enablexxx;

public class Role {

}

package com.gcx.spring.z_springboot_Enablexxx;

public class User {

}
 

我們在App.class呼叫的話 會顯示異常，告訴你Spring容器中並沒有這個bean

System.out.println(context.getBean(User.class));
System.out.println(context.getBean(Role.class));

這時候我們在App.class上加入@Import註解

@Import({User.class,Role.class})

@Import既可以裝載一個或者多個類交給spriing容器處理，也可以裝載配置類MyConfig

package com.gcx.spring.z_springboot_Enablexxx;

import org.springframework.context.annotation.Bean;

public class MyConfig {

	@Bean
	public Runnable createRunnble1() {
		return () -> {};	
	}
	
	@Bean
	public Runnable createRunnble2() {
		return () -> {};	
	}
	
	
}

它還提供ImportSelector類靜態注入Spring容器，我們建立一個MyImportSelector類來實現這個介面

package com.gcx.spring.z_springboot_Enablexxx;

import org.springframework.context.annotation.ImportSelector;
import org.springframework.core.type.AnnotationMetadata;

/**
 * 返回值是一個class 該class必須是全稱 這樣會被spring容器託管
 * @author Administrator
 *
 */
public class MyImportSelector implements ImportSelector{

	@Override
	public String[] selectImports(AnnotationMetadata importingClassMetadata) {
		//可以獲取到註解資訊，然後根據註解資訊動態的返回被spring容器託管的bean
		System.out.println(importingClassMetadata.getAnnotationAttributes(EnableLog.class.getName()));
		return new String[]{User.class.getName(),Role.class.getName(),MyConfig.class.getName()};
	}

}

package com.gcx.spring.z_springboot_Enablexxx;

import java.lang.annotation.Documented;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

import org.springframework.context.annotation.Import;

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(MyImportSelector.class)
public @interface EnableLog {

	String name();
}

結果發現bean被全部注入到Spring容器，還可以列印註解資訊

有靜態的就有動態的注入

我們建立一個新類MyImportBeanDefinitionRegistrar實現ImportBeanDefinitionRegistrar

package com.gcx.spring.z_springboot_Enablexxx;

import org.springframework.beans.factory.config.BeanDefinition;
import org.springframework.beans.factory.support.BeanDefinitionBuilder;
import org.springframework.beans.factory.support.BeanDefinitionRegistry;
import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;
import org.springframework.core.type.AnnotationMetadata;

public class MyImportBeanDefinitionRegistrar implements ImportBeanDefinitionRegistrar {

	@Override
	public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
		BeanDefinitionBuilder  beanDefinitionBuilder=BeanDefinitionBuilder.rootBeanDefinition(User.class);
		BeanDefinition beanDefinition=beanDefinitionBuilder.getBeanDefinition();
		registry.registerBeanDefinition("User", beanDefinition);
	}

}

結果控制檯同樣輸出bean被裝載

靜態的是有返回值的，動態的是沒返回值