package com.ard.work.websocket.config;

import com.ard.work.websocket.utils.PTZWebSocketUtils;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.Resource;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.stereotype.Component;

/**
 * 将 wsPushExecutor 静态注入 PTZWebSocketUtils,启用异步并行广播
 *
 * @author 刘苏义
 */
@Component
public class PTZWebSocketInitializer {

    @Resource(name = "wsPushExecutor")
    private ThreadPoolTaskExecutor wsPushExecutor;

    @PostConstruct
    public void init() {
        PTZWebSocketUtils.setPushExecutor(wsPushExecutor);
    }
}