import uuid

import threading

class Task:

"""

线程需要执行的逻辑任务

"""

def __init__(self, func, *args, **kwargs):

self.callable = func

self.id = uuid.uuid4()

self.args = args

self.kwargs = kwargs

def __str__(self):

return "Task ID: " + str(self.id)

class AsyncTask(Task):

def __init__(self, func, *args, **kwargs):

self.result = None

self.condition = threading.Condition()

super().__init__(func, *args, **kwargs)

def set_result(self, result):

self.condition.acquire()

self.result = result

self.condition.notify()

self.condition.release()

def get_result(self):

self.condition.acquire()

if not self.result:

self.condition.wait()

result = self.result

self.condition.release()

return result

def my_func(*args, **kwargs):

print("this is a testing text")

if __name__ == '__main__':

task = Task(func=my_func)

print(task)