【云+社区年度征文】JAVA的两年半学习

@Component
public class BRunner implements IRunner, ApplicationListener<NoticeEvent> {
    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;

    @Override
    public void run() {
        System.out.println("this is BRunner"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        try {
            Thread.sleep(10_000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        NoticeEvent noticeEvent = new NoticeEvent(this,"C");
        applicationEventPublisher.publishEvent(noticeEvent);
    }

    @Override
    @Async
    public void onApplicationEvent(NoticeEvent noticeEvent) {
        if ("B".equalsIgnoreCase(noticeEvent.getMessage())){
            this.run();
        }
    }
}

public class NoticeEvent extends ApplicationEvent {

    private String message;

    public NoticeEvent(Object source, String message) {
        super(source);
        this.message = message;
    }

    public NoticeEvent(Object source) {
        super(source);
    }

    public String getMessage() {
        return message;
    }
}

@Component
public class ARunner implements IRunner {

    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;


    @Override
    public void run() {
        System.out.println("this is ARunner"+new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        try {
            Thread.sleep(10_000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        NoticeEvent noticeEvent = new NoticeEvent(this,"B");
        applicationEventPublisher.publishEvent(noticeEvent);
    }
}

1. 维护一个静态集合存储需要剔除的`task`名称，容器初始化的时候加载进去，在执行时候判断是否在此集合中。
2. 利用`instanceof`去判断当前task是否属于`ApplicationListener`，属于就剔除执行计划。