method의 호출 횟수 제한 방식?

예전에 1번으로

class ScheduleQueue(threading.Thread):
....# (Function, Args, Callback) tuple queue
....def __init__(self, exec_per_sec):
........threading.Thread.__init__(self)
........self.daemon = True
........self.time_log = deque()
........self.schedule_queue = deque()
........self.exec_per_sec = exec_per_sec

....def __len__(self):
........return len(self.schedule_queue)

....def push(self, func, args, callback):
........self.schedule_queue.append((func, args, callback))

....def exec(self):
........while len(self.schedule_queue) == 0:
............time.sleep(0.1)

........while len(self.time_log):
............front = self.time_log[0]
............if front > datetime.today() - timedelta(seconds=1):
................break
............self.time_log.popleft()

........if len(self.time_log) == self.exec_per_sec:
............time.sleep((self.time_log[0] + timedelta(seconds=1) - datetime.today()).total_seconds())
............return

........while len(self.time_log) < self.exec_per_sec and len(self.schedule_queue):
............func, args, callback = self.schedule_queue.popleft()
............if callback:
................callback(*func(*args))
............else:
................func(*args)
............self.time_log.append(datetime.today())

API 호출 큐를 이런식으로 구현해놨었던 것 같은데 작동은 잘 됐던 것 같은데 이것도 문제가 좀 있을 것 같아서 어떻게 고치면 좋을지 프로그래밍 게시판 아조씨들의 고견을 듣고싶네요

오타가 넘 많아서 수정..

비공개 손님 … 2017-12-03 05:10:17

7// exec_per_sec가 10보다 클때, 함수 수행시간이 함수 호출 간격보다 작으면 초당 10회로 고정되는 문제가 있겠네요.

비공개 손님 … 2017-12-03 07:40:25

냉 스케쥴 큐가 비어있는 상황에서도 sleep을 안주면 너무 많은 시간을 낭비 할 것 같아서 그냥 무작정 0.1초 슬립을 줬는데 그런 케이스도 생각 해 볼 수 있겠군요

비공개 손님 … 2017-12-03 08:04:21

큐가 0인 경우 P

push할때 V하게 고쳐 봤는데 이렇게 만드는 방향이 맞을까요?

비공개 손님 … 2017-12-03 12:01:58

thread event로 push후 set하고, sleep대신 wait-clear를 하는 정도로 충분하죠

비공개 손님 … 2017-12-03 14:58:32

아하 thread event라는게 있군요. push에set하고 sleep대신 clear이후 wait하게 바꿨슴다. 더 없을까요?

댓글을 작성하실 수 없습니다.
(권한이 없는 회원레벨)

목록으로

TOP arrow_upward