多线程循环锦标赛

Question

我正在尝试测试 8 种不同的游戏算法。这些算法可以与遵循游戏界面的不同类型的游戏相互对抗。

所以，他们必须互相对抗 100 场比赛。我已经完成了那部分，它工作正常。现在，我正在尝试使其成为多线程，以利用朋友计算机的 8 核。

我很少有使用线程的经验。那么，为了使我的代码成为多线程，我必须进行哪些更改？

这是我的单线程版本的代码。

编辑：我想到的解决方案（以我的基本知识）是关于制作一个 Match 类，它需要两个玩家和他们想要玩的游戏。该类将实现 Runnable，我可以为每个游戏创建一个线程。我现在的问题是，一旦 run() 方法完成，我将如何通知结果？

谢谢

for (int p1 = 0; p1 < allPlayers.length; p1++)
{
    for (int p2 = p1 + 1; p2 < allPlayers.length; p2++)
    {    
        for (int t = 0; t < trials; t++)
        {
            int player1 = t % 2 == 0 ? p1 : p2;
            int player2 = t % 2 == 0 ? p2 : p1;
            Player[] players = new Player[] { allPlayers[player1], allPlayers[player2] };
            game.newGame();

            while (!game.isFinished())
                game.playNthMove(players[game.currentPlayer()].move(game));

            data[p1][p2][t] = getCharValue(game.getOutcome()[t % 2 == 0 ? 0 : 1]);
            data[p2][p1][t] = getCharValue(game.getOutcome()[t % 2 == 0 ? 1 : 0]);
        }
    }
}

Answer 1

您不需要修改单线程实现的代码 - 您只需要创建一个实现 Runnable 接口的类并将该功能包装在 run() 方法中。然后你可以创建一个线程，传入该类的一个实例，然后调用Thread.start()。

参考this。

编辑：如何从该线程获取结果：

看起来 Callable Interface 就是您要寻找的。这是link，其中包含有关如何使用它的基本说明。它需要了解如何使用 Runnable 接口来创建没有结果的多线程应用程序的基本知识，所以我建议先阅读this。

Answer 2

Collection<Callable<Void>> tasks = new ArrayList<Callable<Void>();
for (int p1 = 0; p1 < allPlayers.length; p1++)
{
    for (int p2 = p1 + 1; p2 < allPlayers.length; p2++)
    {    
        for (int t = 0; t < trials; t++)
        {
            final int player1 = t % 2 == 0 ? p1 : p2;
            final int player2 = t % 2 == 0 ? p2 : p1;
            final Player[] players = new Player[] { allPlayers[player1], allPlayers[player2] };
            final int trial = t;
            tasks.add(new Callable<Void>() {
               public Void call() {
                 game.newGame();

                 while (!game.isFinished())
                    game.playNthMove(players[game.currentPlayer()].move(game));

                 data[p1][p2][t] = getCharValue(game.getOutcome()[t % 2 == 0 ? 0 : 1]);
                 data[p2][p1][t] = getCharValue(game.getOutcome()[t % 2 == 0 ? 1 : 0]);
                 return null;
              }
           });
        }
    }
}
executor.invokeAll(tasks); // called on an exector, will wait for all tasks to complete

当前设计的问题是游戏对象看起来不是线程安全的。您可能希望每个 Runnable 都有一个新的游戏对象。

Answer 3

没有灵丹妙药。在问这个问题之前，您需要了解基础知识。从阅读 MSDN 上的这篇文章开始：http://msdn.microsoft.com/en-us/magazine/cc163744.aspx。 Java 也差不多。

完成后，回来就你自己尝试遇到的问题提出另一个问题。

当然，您可能会在这里得到另一个答案，告诉您该怎么做。但是请，不要阅读那个答案。在继续之前了解基础知识至关重要。否则，当您的应用停止运行时，您将完全迷失。