1

我正在尝试运行 2 个并发线程，其中一个不断将对象添加到列表中，另一个更新这些对象，并且也可能从列表中删除其中一些对象。我有一个ArrayList用于我的方法和类的整个项目，所以现在很难改变它。

我环顾四周，发现了几种方法，但正如我所说，很难从ArrayList. 我尝试使用synchronizedand notify()for 将对象添加到列表wait()中的方法，以及更改这些对象的方法，如果它们符合某些条件，则可能会删除它们。

现在，我已经想出了如何使用 a 来做到这一点CopyOnWriteArrayList，但我想知道是否有可能使用ArrayList它自己来模拟这个。这样我就不必编辑我的整个代码。

所以，基本上，我想做这样的事情，但是ArrayList：

import java.util.Iterator;
import java.util.concurrent.CopyOnWriteArrayList;

public class ListExample{
    CopyOnWriteArrayList<MyObject> syncList;

    public ListExample(){
        syncList = new CopyOnWriteArrayList<MyObject>();

        Thread thread1 = new Thread(){
            public void run(){
                synchronized (syncList){
                    for(int i = 0; i < 10; i++){
                        syncList.add(new MyObject(i));
                    }
                }
            }
        };

        Thread thread2 = new Thread(){
            public void run(){
                synchronized (syncList){
                    Iterator<MyObject> iterator = syncList.iterator();
                    while(iterator.hasNext()){
                        MyObject temp = iterator.next();

                        //this is just a sample list manipulation
                        if (temp.getID() > 3)
                            syncList.remove(temp);

                        System.out.println("Object ID: " + temp.getID() + " AND list size: " + syncList.size());
                    }
                }
            }
        };

        thread1.start();
        thread2.start();
    }

    public static void main(String[] args){
        new ListExample();
    }
}

class MyObject{
    private int ID;

    public MyObject(int ID){
        this.ID = ID;
    }

    public int getID(){
        return ID;
    }

    public void setID(int ID){
        this.ID = ID;
    }
}

我也读过，Collections.synchronizedList(new ArrayList())但我相信这将需要我更改我的代码，因为我有大量的方法可以ArrayList作为参数。

任何指导将不胜感激，因为我没有想法。谢谢你。

4

4 回答 4

5

您可能对java.util.concurrent包提供的收藏感兴趣。它们对于生产者/消费者场景非常有用，其中一个或多个线程将事物添加到队列中，而其他线程获取它们。有不同的方法取决于您是要阻塞还是在队列满/空时失败。

关于重构您的方法，您应该使用接口（例如List）而不是具体的实现类（例如ArrayList）。这就是接口的目的，Java API 提供了很好的接口。

于 2013-03-12T05:34:08.343 回答
1

作为一种快速解决方案，您可以扩展 ArrayList 并使修改方法（添加/删除）同步。并重构代码以将 ArrayList 替换为您的自定义 ArrayList

于 2013-03-12T05:34:26.727 回答
1

使用Vector而不是ArrayList. 请记住将其存储在List引用中，因为 Vector 包含不推荐使用的方法。与 ArrayList 不同，Vector 会同步其内部操作，而与 ArrayList 不同CopyOnWriteArrayList，它不会在每次进行修改时复制内部数组。

于 2013-03-12T06:01:43.187 回答
1

当然你应该使用java.util.concurrent包。但是，让我们看看仅ArrayList和同步会发生什么/可能发生什么。

在您的代码中，如果您只是ArrayList代替，它应该可以工作，因为您已经为您在线程中所做/操作的任何事情CopyOnWriteArrayList提供了完全同步。synchronized (syncList)如果整个事情是同步的，则不需要任何wait() notify()内容​​（但不建议这样做，以后会这样）。

但是这段代码会给出ConcurrentModificationException，因为一旦你使用迭代器syncList.iterator()，你不应该从该列表中删除元素，否则它可能会在迭代时产生不良结果，这就是它被设计为快速失败并给出异常的原因。为避免这种情况，您可以使用如下：

                Iterator<MyObject> iterator = syncList.iterator();
                ArrayList<MyObject> toBeRemoved = new ArrayList<MyObject>();
                while(iterator.hasNext()){
                    MyObject temp = iterator.next();

                    //this is just a sample list manipulation
                    if (temp.getID() > 3)
                    {
                        //syncList.remove(temp);
                        toBeRemoved.add(temp);
                    }
                    System.out.println("Object ID: " + temp.getID() + " AND list size: " + syncList.size());
                }
                syncList.removeAll(toBeRemoved);

现在关于同步，你应该努力最小化它的范围，否则线程之间会有不必要的等待，这就是为什么 java.util.concurrent 包在多线程中具有高性能（甚至使用非阻塞算法）。或者你也可以使用Collections.synchronizedList(new ArrayList())，但它们不如concurrent类。

如果你想像在生产者/消费者问题中那样使用条件同步，那么你可以wait() notify()在同一个对象上使用机制（锁）。但是同样已经有一些类可以帮助使用java.util.concurrent.LinkedBlockingQueue.

于 2013-03-12T06:15:04.597 回答