|
|
|
|
@ -5,6 +5,7 @@ import java.util.Arrays;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
|
|
import javax.annotation.PostConstruct;
|
|
|
|
|
import javax.annotation.PreDestroy;
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
|
|
|
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
@ -33,6 +34,15 @@ public class CfsDaemon {
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
//@PreDestroy
|
|
|
|
|
public void onDestroyed() {
|
|
|
|
|
for(MovingOutDaemonThread daemon : movingOutDaemons){
|
|
|
|
|
if(!daemon.isInterrupted()){
|
|
|
|
|
daemon.interrupt();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public void createThread() {
|
|
|
|
|
|
|
|
|
|
movingOutDaemons = new ArrayList<MovingOutDaemonThread>();
|
|
|
|
|
|