package tech.powerjob.server.test;

import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;
import tech.powerjob.common.utils.CommonUtils;
import tech.powerjob.server.core.uid.SnowFlakeIdGenerator;

import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.stream.Collectors;

/**
 * @author Echo009
 * @since 2022/4/27
 */
@Slf4j
public class ConflictTest {

    @Test
    @SuppressWarnings("all")
    @SneakyThrows
    public void segmentLockMockTest() {

        final SnowFlakeIdGenerator snowFlakeIdGenerator = new SnowFlakeIdGenerator(0, 4);

        int len = CommonUtils.formatSize(1024) - 1;
        Map<Integer, Integer> matchCount = new TreeMap<>();
        int maxTime = 10000;
        int expectedMaxConflict = maxTime / len;

        for (int i = 0; i < maxTime; i++) {
            final long id = snowFlakeIdGenerator.nextId();
            // 这里模拟实际的请求间隔，新建任务在 1k 的 qps
            Thread.sleep(1);
//             int res = Long.valueOf(id).intValue() & len;
            int res = String.valueOf(Long.valueOf(id).intValue()).hashCode() & len;
            matchCount.merge(res, 1, Integer::sum);
        }
        final List<Map.Entry<Integer, Integer>> sorted = matchCount.entrySet().stream().sorted((a, b) -> b.getValue() - a.getValue()).collect(Collectors.toList());
        // 10w qps （这里包括实例状态上报的请求），最大冲突次数 407，假设每个请求处理耗时 10 ms，最大等待时长 4.07 s
        log.info("expectedMaxConflict: {},actualMaxConflict: {}", expectedMaxConflict, sorted.get(0).getValue());
        sorted.forEach(e -> {
            log.info("index: {} -> conflict: {}", e.getKey(), e.getValue());
        });

    }


}