在所有函数创建谁没有可用共享股票列表。然后，它运行警报（循环功能），以在库存可用时提醒我。我需要同时运行所有这些警报循环，但是所有人都在开始下一个循环之前都等待着第一个库存可用。
我尝试使用线程为每个股票创建线程，但是我无法等待Thread.start（）
async def all(self, ctx):
stocks = requests.get(f'https://api.torn.com/torn/?
selections=stocks&key={api}').json()['stocks']
zero = []
acronymz = []
for items in stocks:
if stocks[items]['available_shares'] == 0:
zero.append(items)
acronymz.append(stocks[items]['acronym'])
await ctx.send(f'Zero: {zero}')
for acronyms in zero:
print(acronyms)
# Thread(target=alert, args=(ctx, acronyms)).start()
await alert(ctx, acronyms)
# await asyncio.sleep(0.5)
async def alert(ctx, items):
stocks = requests.get(f'https://api.torn.com/torn/?selections=stocks&key={api}').json()['stocks'][items]
if stocks['available_shares'] == 0:
await ctx.send(f'I am now watching {stocks["acronym"]}. I will let you know when there are shares available!')
while stocks['available_shares'] == 0:
stocks = requests.get(f'https://api.torn.com/torn/?selections=stocks&key={api}').json()['stocks'][items]
print(stocks)
await asyncio.sleep(5)
await ctx.send(f'There are {stocks["available_shares"]} in {stocks["acronym"]}')
股票= https://pastebin.com/FhuR4d4R [“股票”]
您可以为事件循环安排任务，而无需await立即执行。这是一个使用示例asyncio.gather
await asyncio.gather(*(alert(ctx, acronyms) for acronyms in zero))
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句