Skip to content

QueuedLogHandler worker 终止条件问题 #152

Open
@georgexsh

Description

@georgexsh

现在的实现即使队列为空,也要等足 close_wait 这里的必要性是什么呢?

 def _post(self):
     while not self.stop_flag or (time() - self.stop_time) <= self.close_wait:
         items = self._get_batch_log_items(self.put_wait)
         if not items:
             continue

         # 发送逻辑

造成的问题是,在进程结束时,要无谓等待 5 秒钟。

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions