Redis 实现分布式锁

import redis import time import math import threading import typing from redis import Redis class _WatchThread(threading.Thread): def __init__(self, target, args=(), kwargs={}): super(_WatchThread, self).__init__() self.func = target self.args = args self.kwargs = kwargs self.result = None def run(self): # 接受返回值 self.result = self.func(*self.args, **self.kwargs) def get_result(self, default=None, transform=lambda x: x): # 线程不结束,返回值为None try: return transform(self.result) except Exception as e: r...

Submit