如何在Python中创建并行任务

debugcn 发表于 Dev

巴西费利佩

在初学者的项目中，我正在为电报组创建一个战斗游戏，一个玩家向另一个挑战，然后在聊天中发生战斗。现在，我想为其实现“超时”功能。我设法使它使用_thread起作用：

import _thread
class Battle:
    def __init__(self, chat_id):
        self.chat = chat
        print('Instance of battle started on chat %s' % self.chat)
        self.pcount = 0
        self.p1score = 0
        self.p2score = 0

    def reset(self):
        self.pcount = 0
        self.p1score = 0
        self.p2score = 0

def timeout(chat_id):
    time.sleep(90)
    battle = battledic[chat_id]
    if battledic[chat_id].timer == 1:
        sendmessage(chat_id, 'no one accepted') # first parameter is the chat address and the second one is the message
        battle.reset()
    else:
        return

battle = Battle(chat_id)
if message == "challenge":
    if battle.pcount == 0:
        _thread.start_new_thread(timeout, (chat_id,))
...

因此，基本上我正在做的是调用超时功能，该功能将在另一个线程中睡眠90秒，然后检查是否只有一个玩家（pcount == 1）进行战斗。，它会向聊天室发送一条消息，告知他们战斗未开始，然后重置战斗实例。

这里的问题是我经常提出异常，即使它在大多数情况下都能正常工作，但有时也达不到预期的效果，导致正在进行的战斗结束。经过研究，我发现这样做并不是理想的方式，但是我找不到更好的解决方案，也许我也想同时进行其他聊天中的其他战斗。在这种情况下应该使用什么？合作多任务处理？多处理？trheading模块？感谢您完成此任务的任何提示！

瓦斯

我已经让你开始了。我不确定您将如何聊天或记录谁在玩。

我最初的想法是运行线程，但是while循环更容易。

# from threading import Thread
from time import sleep

no_one = True
battledic = {} # your dict here. It may be better to use a list of objects (classes) for your opponents

class Battle(object):
    def __init__(self, chat_id):
        self.chat_id = chat_id
        self.pcount = 0
        self.p1score = 0
        self.p2score = 0
        print('Instance of battle started on chat %s' % self.chat_id)

    def reset(self):
        self.pcount = 0
        self.p1score = 0
        self.p2score = 0

def wheres_waldo():
    x = 0; no_one = True
    while x < 90: # waits 90 seconds unless found
        for player in battledic.keys():
            if player.is_requesting: # found someone
                no_one = False
                break # quit looking
        else:
            print('No one yet')
        sleep(1); x+= 1
    if no_one:
        sendmessage(chat_id, 'no one accepted') # first parameter is the chat address and the second one is the message
        battle.reset()
    else:
        sendmessage(chat_id, 'Found someone')

def sendmessage(chat_id,message):
    print('%s on chat %s' % (message,chat_id))

battle = Battle(chat_id)
while True:
    message = raw_input('Command? ')
    if message == "challenge":
        if battle.pcount == 0:
            wheres_waldo()
            # first thoughts were to run threads but the while loop is easier
            # wait = Thread(target=timeout, args=(chat_id))
            # where = Thread(target=wheres_waldo)
            # wait.start();where.start()
            # wait.join();where.join()

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。