import logging
import multiprocessing
import threading

import concurrent.futures
import time

from utils import tool


def task_function(task_param, j):
    # 这里是任务的具体逻辑，task_param是任务的参数
    # 可以在这里进行耗时的计算、IO操作等

    print(time.time(), task_param, j, id(threading.current_thread()))

    time.sleep(2)

    # 返回任务的结果
    return f"result:{task_param}"


def call_back(result):
    print(time.time(), "call_back", id(threading.current_thread()))


def run_process_1(pipe):
    thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=20)

    def process_data(val):
        print("处理任务", val)
        raise Exception("测试异常")

    def recv_data():
        while True:
            try:
                val = pipe.recv()
                if val:
                    thread_pool.submit(process_data, val)
            except Exception as e:
                logging.exception(e)

    threading.Thread(target=lambda: recv_data(), daemon=True).start()
    while True:
        time.sleep(2)


def run_process_2(pipe):
    def send_data():
        while True:
            time.sleep(2)
            for i in range(1):
                pipe.send("test: " + tool.get_now_time_str())

    threading.Thread(target=lambda: send_data(), daemon=True).start()
    threading.Thread(target=lambda: send_data(), daemon=True).start()
    while True:
        time.sleep(2)


if __name__ == '__main__':
    p1, p2 = multiprocessing.Pipe()
    serverProcess = multiprocessing.Process(target=run_process_1, args=(p1,))
    jueJinProcess = multiprocessing.Process(target=run_process_2, args=(p2,))
    serverProcess.start()
    jueJinProcess.start()

    while True:
        time.sleep(2)