Asyncio .create_task() 未运行传入的函数

Question

我正在尝试制作一个在 python 中执行几个与计时器相关的事情的程序，我需要制作它，以便 Asyncio 通过使用 asyncio.get_event_loop().create_task(timer_function(my_parameters)) 调用另一个函数来创建一个任务（无需等待它），我用过这之前在另一个项目中，它工作得很好，但是，在这种情况下，它最终没有像它应该的那样调用timer_function()，我怀疑它发生是因为它在循环内部或与项目结构相关的东西。我现在找不到任何可以工作的东西，只使用await 设法调用该函数，但最终没有使它并行运行。项目结构如下：

async def timer_function(my_parameters):

   print('Timer_Function called')
   
   # Do stuff with the parameters

   asyncio.sleep(time_based_on_those_parameters)

   # Finish doing some other things



# Note: final() doesn't need to be async, I only made it so
# to try and test some fixes
async def final(parameters):  

   # Do stuff

   while True:  # This part loops forever every minute

      # Do stuff

      for i in range(my_range):

         if some_condition_a:

            asyncio.get_event_loop().create_task(timer_function(my_parameters))

            print('Condition A met')

         if some_condition_b:

            asyncio.get_event_loop().create_task(timer_function(some_different_parameters)

            print('Condition B met')

         # Do some other stuff

   sleep(60)

运行代码后，满足这些条件时打印的所有内容都是

>>> Condition met

但我期望看到的是两者

>>> Condition met
>>> Timer function called

然后我将 await 放在 create_task 部分之前，当时打印的所有内容都是

>>> Timer function called

然后只有当计时器用完并做它需要做的事情是当>>> Condition met 被打印出来。有没有办法改变这种结构以适应 Asyncio 或其他我可以尝试的方法？

编辑：我找到了使用threading 而不是asyncio 的解决方法。代码现在是这样的：

def timer_function(my_parameters): # Sync method now

   print('Timer_Function called')
   
   # Do stuff with the parameters

   sleep(time_based_on_those_parameters) # No longer asyncio.sleep()

   # Finish doing some other things



def final(parameters):  

   # Do stuff

   threads = []

   while True:  # This part loops forever every minute

      # Do stuff

      for i in range(my_range):

         if some_condition_a:

             t = threading.Thread(target=timer_function, args=(my_parameters))
             threads.append(t)
             t.start()          

             print('Condition A met')

         if some_condition_b:

            t = threading.Thread(target=timer_function, args=(my_parameters))
            threads.append(t)
            t.start()

            print('Condition B met')

         # Do some other stuff

   sleep(60)

这现在按预期工作，所以对我来说我不再需要解决这个问题，但是如果有人知道为什么 Asyncio 在这个结构中不这样做，请告诉我，因为有人可能在未来。 （我检查了我制作的另一个项目 asyncio.get_event_loop().create_task(timer_function(my_parameters)) 可以在不等待的情况下调用，不同之处在于在这种情况下它位于 while True 和 for 循环内，而在这种情况下，它只是在事件侦听器上调用一次）

Answer 1

我才开始使用 asyncio，但我的猜测是 create_task 没有运行任何东西，你可以试试 run_until_complete 代替