package org.example.task;

import lombok.extern.slf4j.Slf4j;
import org.example.server.impl.CurrencySerivceImpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @program: demo
 * @description:
 * @create: 2024-07-23 18:01
 **/
@Component
@Slf4j
public class MarketDataTask {

    private final ExecutorService executor = Executors.newSingleThreadExecutor(); // 创建单线程线程池

    @Autowired
    private CurrencySerivceImpl currencySerivce;

    private final Lock syncCurrencyLock = new ReentrantLock();

    @Scheduled(initialDelay = 0, fixedRate = Long.MAX_VALUE)
    public void start() {
        log.info("行情数据计算-------------启动");

        // 启动任务调度器
//        currencySerivce.scheduler();

        executor.execute(() -> {
            try {
                while (true) {
                    syncCurrencyLock.lock();
                    try {
                        long startTime = System.nanoTime();
                        currencySerivce.quotationCalculation();
                        long endTime = System.nanoTime();
                        double durationInSeconds = (endTime - startTime) / 1_000_000_000.0;
                        if(durationInSeconds >= 2){
                            log.info("程序执行时间： " + durationInSeconds + " 秒");
                        }
                    } catch (Exception e) {
                        log.error("行情数据计算错误--------------【严重预警】");
                        e.printStackTrace();
                    } finally {
                        syncCurrencyLock.unlock();
                    }
                }
            } catch (Exception e) {
                log.error("行情数据计算--------------线程被中断");
                Thread.currentThread().interrupt();
            }
        });
    }

}