在 2 个不同的线程中写入和读取 ArrayList

Question

我目前正在为学校开发一个小项目，它是一款塔防游戏。

初始化游戏时，它会启动一个计算所有内容的线程。启动该线程后，我的代码跳入一个循环，循环我的图形代码。我认为它正在使用 2 个线程。一个线程用于计算，另一个是“标准”线程，在您打开程序时使用。

现在我想将射弹添加到我的塔中。为此，我需要向我的实体 ArrayList 添加一个新的 Projectile 对象。每当我尝试这样做时，它都会说

线程“主”java.util.ConcurrentModificationException 中的异常

并指向我的图形循环所在的行，它试图循环我的实体数组。这是有道理的，因为当我的 Projectiles 添加到这个数组中时，我的 graphicsloop 会尝试读取。我尝试使用“同步”，我想我知道如何使用它以及它的用途，但我不确定我会在我的代码中使用它的什么地方。我从昨天开始尝试解决这个问题，但在互联网上找不到任何解决方法。另外我不确定哪段代码对你有帮助，如果你不明白我的程序是如何工作的以及问题是什么，所以如果你需要什么，请随时询问。

如果有人能帮我解决这个问题，我已经想感谢你了，如果你还在阅读，那就太棒了

编辑：我认为这些是重要的代码：

世界更新方法：

private void updateRunning() {
    waveTimer();
    for (Entity e : entities) {
        if (e.isMonster() && !block) {
            e.toMonster().move();
            if (e.toMonster().getHealth() <= 0)
                entities.remove(e);
        } else if (e.isTower()) {
            e.toTower().setTarget(e.toTower().findTarget());
            e.toTower().shoot();
        } else if (e.isProjectile()) {
            e.toProjectile().update();
        }
    }
}

渲染器循环方法：

private void updateRunning() {
    cam.update();
    for (Entity ent : world.getEntities()) {
        ent.draw();
    }
    cursor.update();
    cursor.draw(); // Must always be on bottom draw-methods, to be drawed
                   // on top of
                   // everything else
    cam.refresh();
}

edit2

private void addWave() {
  if (wave % 3 == 1) {
    for (int i = 0; i < 6; i++) {
      entities.add(new Monster(this, i + 1, path.getCoord(0).x,  
                   path.getCoord(0).y - i * 57, 0.35f, Assetloader.monster01));
    }
  } else if (wave % 3 == 2) {
  } else {
  }
}

private void attack(Monster target, float damage) {
  world.addEntity(new Projectile(world, vec.x, vec.y, 20, 20, target,  
                this, Assetloader.cursor01));
  ready = false;
  lastShot = System.currentTimeMillis();
}

public void addEntity(Entity e) {
  this.entities.add(e);
}

Answer 1

只需使用迭代器功能在迭代时删除一个项目：

private void updateRunning() {
        waveTimer();
        Iterator<Entity> iterator = entities.iterator();
        while(iterator.hasNext()) {
            Entity e = iterator.next();
            if (e.isMonster() && !block) {
                e.toMonster().move();
                if (e.toMonster().getHealth() <= 0)
                    iterator.remove(e);
            } else if (e.isTower()) {
                e.toTower().setTarget(e.toTower().findTarget());
                e.toTower().shoot();
            } else if (e.isProjectile()) {
                e.toProjectile().update();
            }
        }
    }

这与线程无关，只是不能在使用 for-each 循环迭代列表时从列表中删除元素。

Answer 2

当您需要在多个线程中收集数据时，您应该使用支持并发的结构。在 Java 中，可以在 java.util.concurrent 包中找到此类类。对于您的情况，您应该使用 CopyOnWriteArrayList 类而不是 ArrayList。

根据我的经验，使用ArrayList 或ArrayList 的并发支持变体不是这些情况的最佳选择。最好使用像ConcurrentLinkedQueue 这样的并发队列。

Answer 3

如果你想使用synchronized，你必须这样做

synchronized(myList) {
    //Do stuff
}

所以当另一个线程在同步块中时，没有其他线程可以访问该列表。 但请注意deadlocks

这里有关于synchronized 的教程 http://tutorials.jenkov.com/java-concurrency/synchronized.html

Answer 4

您可以使用并发集合包中的CopyOnWriteArrayList 来自动同步访问。

请注意，顾名思义，每次写入都会复制内部 array，因此这在性能方面可能具有挑战性。

否则，您可能想要更底层并尝试使用ReentrantReadWriteLock。

Answer 5

从您的问题看来，您似乎在多个线程之间共享一个数据结构。合适的类是java.util.Vector，因为它（或多或少）是ArrayList的同步版本