def on_queue_empty(self, queue, max_num=100):
for _ in range(max_num):
try:
item = self.list_data.popleft()
if '/' in item:
mask = ipaddr.IPv4Network(item)
ip_list = [text_type(t) for t in mask.iterhosts()]
else:
ip_list = [item]
queue.extend(ip_list)
except IndexError:
break
try:
item = queue.popleft()
except IndexError:
item = None
return item
评论列表
文章目录