执行特定作战需求文件中的任务

Question

我有一个循环：

listGames = []
for home in range(totalPlayers - 1):
    for away in range(home + 1, totalPlayers):
        listGames.append((home, away))

print listGames
match_num = 1
for game in listGames:
    player1 = listPlayers[game[0]]
    player2 = listPlayers[game[1]]
    do_stuff(player1, player2)

当有很多玩家时，这个循环可能需要相当长的时间，所以我们希望使用线程来更快地完成循环。但是，player1和player2是类的实例，因此同时使用它们进行操作是不好的。编辑：这些“任务”的执行顺序在其他方面并不重要。你知道吗

我找到了http://www.troyfawkes.com/learn-python-multithreading-queues-basics/，这似乎正是我想要的，但我不确定如何调整它以确保一次只运行一个类/播放器实例

（简单）示例：

totalPlayers = 4

0, 1, 2, 3
listGames = [(0, 1), (0, 2), (0, 3), (1, 2), (1, 3), (2, 3)]

所以，游戏（0，1），（2，3）可以同时执行，但是其他的必须等到这些完成

提示/想法？你知道吗

Answer 1

下面是一个示例程序，它展示了一种方法。其思想是创建一个multiprocessing.Pool来同时运行do_stuff的多个实例。我们还维护一个set来跟踪当前由do_stuff实例处理的所有播放器，这样我们就不会同时处理同一个播放器多次。当do_stuff完成它的工作时，它告诉父进程它已经完成了对播放器的处理，这样就可以处理使用这些播放器的新任务。你知道吗

import time
import multiprocessing
from Queue import Empty

listGames = [(0, 1), (0, 2), (0, 3), (1, 2), (1, 3), (2, 3)] 

def do_stuff(players):
    player1, player2 = players
    print("player1 {} player2 {}".format(player1, player2))
    time.sleep(5)
    # Imagine some other stuff happens here.
    print ("now done with {} and {}".format(player1, player2))
    q.put((player1, player2))

if __name__ == "__main__":
    q = multiprocessing.Queue()
    pool = multiprocessing.Pool()
    gamesSet = set(listGames)  # Convert to a set for efficiency reasons.
    running = set()  # This keeps track of players being processed.
    while gamesSet:
        to_remove = []
        for player in gamesSet:  
            if player[0] not in running and player[1] not in running:
                running.add(player[0])
                running.add(player[1])
                pool.apply_async(do_stuff, (player,))
                to_remove.append(player)
        for player in to_remove:
            gamesSet.remove(player)
        while True:
           # Find out if we're done processing any players.
           try:
               done = q.get_nowait()
               running.remove(done[0])
               running.remove(done[1])
           except Empty:
               break
    pool.close()
    pool.join()

输出：

dan@dantop2:~$ ./mult.py 
player1 0 player2 1
player1 2 player2 3
now done with 0 and 1
now done with 2 and 3
player1 1 player2 2
player1 0 player2 3
now done with 0 and 3
now done with 1 and 2
player1 1 player2 3
player1 0 player2 2
now done with 1 and 3
now done with 0 and 2

Answer 2

除非do_stuff()是IO绑定的，否则这可能会使您的代码because of the global interpreter lock变慢。基于您所说的“当有很多玩家时，这可能需要时间”的说法，我倾向于认为您的程序可能是CPU受限的—在这种情况下，多线程可能会损害您的性能。你知道吗

说到你原来的问题，你要的是两个元素子集中的exact cover，不幸的是，这是NP完全的。你知道吗