package com.product.admin.service;


import com.product.core.exception.BaseException;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

/**
 * @program: base-server-admin
 * @description: 更新用户信息独立线程类
 * @author: xu peng cheng
 * @create: 2020-12-22 14:17
 */
@Component
public class ThreadUpdateUserInfoService {

    protected List<Object[]> users = Collections.synchronizedList(new ArrayList<>());

    protected UpdateUserThread updateUserThread;

    protected static ThreadUpdateUserInfoService threadUpdateUserInfoService;

    /**
     * 回调方法接口
     */
    public interface CallBack {
        void method(Object... objects);
    }

    public synchronized void add(CallBack callBack, Object[] params) {
        synchronized (users) {
            users.add(new Object[]{callBack, params});
        }
    }

    /**
     * 获取当前类实例
     *
     * @return
     */
    public static synchronized ThreadUpdateUserInfoService getInstance() {
        if (threadUpdateUserInfoService == null) {
            threadUpdateUserInfoService = new ThreadUpdateUserInfoService();
        }
        return threadUpdateUserInfoService;
    }

    /**
     * 取出数据
     *
     * @return
     */
    private synchronized List<Object[]> getUsers() {
        List<Object[]> user = new ArrayList<>();
        synchronized (users) {
            user.addAll(users);
            users.clear();//清除数据
        }
        return user;
    }

    /**
     * 启动独立线程刷新用户信息
     */
    public synchronized void start() {
        if (updateUserThread == null || updateUserThread.getState() == Thread.State.TERMINATED) {
            updateUserThread = new UpdateUserThread("update-user-info-thread");
            updateUserThread.start();
        }
    }

    /**
     * 线程内部类
     */
    class UpdateUserThread extends Thread {

        public UpdateUserThread(String name) {
            setName(name);
        }

        @Override
        public void run() {
            while (!isInterrupted()) {
                List<Object[]> pop = getUsers();
                try {
                    Thread.currentThread().sleep(3000);
                    if (pop.size() > 0) {
                        for (int i = 0; i < pop.size(); i++) {
                            try {
                                Object[] objects = pop.get(i);
                                CallBack callBack = (CallBack) objects[0];
                                Object[] params = (Object[]) objects[1];
                                //调用方法
                                callBack.method(params);
                            } catch (BaseException e) {
                                e.printStackTrace();
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    } else {
                        interrupt();
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }
}