| | |
| | | import com.zy.acs.manager.manager.service.CodeService; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.context.annotation.DependsOn; |
| | | import org.springframework.core.io.ClassPathResource; |
| | | import org.springframework.core.io.Resource; |
| | | import org.springframework.stereotype.Component; |
| | |
| | | */ |
| | | @Slf4j |
| | | @Component |
| | | @DependsOn("mapDataDispatcher") |
| | | public class AvoidWaveCalculator { |
| | | |
| | | private static final ReentrantLock lock = new ReentrantLock(Boolean.TRUE); |
| | |
| | | public void execute() { |
| | | this.singleThreadExecutor = Executors.newSingleThreadExecutor(); |
| | | this.singleThreadExecutor.execute(() -> { |
| | | |
| | | try { Thread.sleep(200); } catch (InterruptedException ignore) {} |
| | | try { Thread.sleep(500); } catch (InterruptedException ignore) {} |
| | | |
| | | this.calcDynamicNodeWhenBoot(); |
| | | |
| | | // while (!Thread.currentThread().isInterrupted()) { |
| | | // |
| | | // this.calcWaveScope(); |
| | | // |
| | | // try { Thread.sleep(500); } catch (InterruptedException ignore) {} |
| | | // } |
| | | |
| | | }); |
| | | } |
| | | |