CallerRunsPolicy

    private ThreadPoolExecutor readExecutor  = new ThreadPoolExecutor(2, 2, 10, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(100), new ThreadPoolExecutor.CallerRunsPolicy());

    public static void main(String[] args) {
        new ThreatTest().deal();
        System.exit(0);
    }

    public void deal() {


        for (int i = 1; i <= 10000; i++) {
            // 门店公司不玩跳公
            int finalI = i;
            readExecutor.execute(() -> execute(finalI));
            System.out.println("run" + i);
        }

        while (true) {
            if (writeExecutor.isTerminated() && readExecutor.isTerminated()) {

                break;
            }
        }
    }

    private void execute(int i) {
        try {
            Thread.sleep(1000);
            System.out.println(i);
        } catch (InterruptedException e) {

        }
        return;
    }

func taskQueueJob(id int, wg *sync.WaitGroup, ch chan struct{}, maxChan chan struct{}) {
	defer func() {
		<-ch // 任务完成后从通道中取出一个元素
		<-maxChan
		wg.Done()
	}()
	task(id)

}
func task(id int) {
	fmt.Printf("Task %d is running...\n", id)
	time.Sleep(1 * time.Second)
	fmt.Printf("Task %d has been completed\n", id)
}

func runCallerRunsPolicy(cmd *cobra.Command, args []string) {
	taskQueue := make(chan struct{}, 10)
	maxTask := make(chan struct{}, 2)
	wg := sync.WaitGroup{}
	for i := 1; i <= 15; i++ {
		select {
		case taskQueue <- struct{}{}:
			maxTask <- struct{}{}
			wg.Add(1)
			go taskQueueJob(i, &wg, taskQueue, maxTask)
		default:
			fmt.Printf("Task %d is executed by the main process\n", i)
			task(i)
		}
	}

	close(taskQueue)
	wg.Wait()
	close(maxTask)

}