循环静态 Set-java

Question

我的代码中有：

public static Set<Long> workItemsForTasks = new HashSet<Long>();

它是一个 Web 应用程序，在代码中用户可以向地图添加新项目 - 我在代码中添加如下：

WorkflowOperations.workItemsForTasks.add(workItem.getId());

一旦工作流程到达特定代码，我就会像这样循环遍历地图：

 Iterator workItemsIter = service.workItemsForTasksToBMS.iterator();
   while (workItemsIter.hasNext()) {
workItemsIter.remove();

    ...
    }

我的问题是：

一旦我得到迭代器 - 如果另一个用户向地图添加了一个新项目（因为它不在同一个互联网页面中） - 当我循环它时它会影响地图吗？或者检索迭代器可以确保它保留映射大小直到循环开始的时间？

已编辑

这是一个接受不同 Web 服务调用的 Web 应用程序。

在调用 A 中，用户可能添加在调用 BI 中需要处理的数据。

因此，我定义了一个单例类（通过 spring bean），它保存我需要处理的数据集（数据是数字），并且每次我有 Web 服务调用 A 时，我都会修改该集。一旦用户请求 Web 服务致电 B - 我必须收集到目前为止的数据并用它执行一些操作。

Answer 1

是否从多个线程同时访问该集合？

如果这一切都发生在一个线程上，那么你所做的就很好。

但是，如果存在并发访问，那么您就做错了两件事。首先，HashSet 不是线程安全的。其次，在迭代 HashSet 时修改它（通过迭代器除外）是错误的，并且会（希望如此！）产生 ConcurrentModificationException 。

您可以通过考虑 java.util.concurrent 中的类来解决这个问题，或者您也可以将一些您自己的同步添加到您的案例中。您可以同步对集合的访问，并且当您需要从中删除内容时，可以一次性完成所有操作。

private static void doMyStuff() {
    Set<Long> myWorkingSet;
    synchronized (workItemsForTasks) {
        myWorkingSet = new HashSet(workItemsForTasks);
        workItemsForTasks.clear();
    }
    for (long x : myWorkingSet) {
        // do something
    }
}

如果您执行类似的操作，则应将 workItemsForTasks 隐藏在类中的访问方法后面，以便保证正确的同步。

Answer 2

静态通常是一件坏事。每次看到它时，请小心

此代码将在多线程环境中执行，因此您编写的内容将不起作用 - 您将得到 ConcurrentModificationException

you don't have a domain model！多头组没有意义。尝试用更高层次的抽象来表达正在发生的事情。

你没有遵循“告诉不要问”，并且特别违反了 LoD-F (http://pragprog.com/articles/tell-dont-ask) - 这是一种说你的代码很快将很难遵循的方式什么。

或者，要破解大部分有效的功能，请使用 CopyOnWriteArraySet。

Answer 3

首先，我假设当您说地图时，您实际上是指 设置。根据 Java 文档，

请注意，此实现不是同步的。如果是多线程
同时访问一个哈希集，并且至少有一个线程
修改集合，必须在外部同步。这是
通常通过同步某个对象来完成，该对象自然地
封装了集合。如果不存在这样的对象，则该集合应该是
使用 Collections.synchronizedSet 方法“包装”。这是最好的
在创建时完成，以防止意外的不同步访问
套装：

HashSet 的线程安全实现如下：就

Set s = Collections.synchronizedSet(new HashSet(...));

Iterator 而言，在存在不同步并发修改的情况下不可能做出任何硬保证，因此您应该在迭代返回的集合时手动同步返回的集合，否则结果将是不确定的。

Set workItemsForTasks = Collections.synchronizedSet(new HashSet());
synchronized(workItemsForTasks) {
Iterator workItemsIter  = workItemsForTasks.iterator(); //Must be in synchronized block
while (workItemsIter.hasNext())
    //Do Something
}