0

У меня метод, который сливает элементы коллекции, если поля этих элементов, подходят под определенные условия. И при определенных условиях какие-то из элементов надо удалить прямо на ходу, но при использовании циклов foreach я не могу использовать удаление из коллекции так как натыкаюсь на ConcurrentModificationException. И мне приходится ходить по коллекции двойным циклом используя счетчик, и все время дергать методы get(...).

Проблема заключается в том что операция remove(...) для ArrayList очень дорогая так как надо сдвигать все элементы. А операция get(...) дорогая для LinkedList. Таким образом получается что мне совершенно необходимо избавится либо от одной операции, либо от другой.

И я попал в не приятную вилку: беру LinkedList, и убираю get() - получаю ConcurrentModificationException, беру ArrayList из-за метода remove(...) теряю всю производительность.

Помогите пожалуйста выйти из этой ситуации, так что-бы не терять производительность.

Вот мой код:

@Override
public Collection<Order> automaticDeals(List<Order> orders) {
    for (int i = 0; i < orders.size(); i++) {
        for (int j = 1 ;j < orders.size(); j++) {
            List<Order> forDelete = deal(orders.get(i), orders.get(j));
            for (Order order : forDelete) {
                orders.remove(order);
            }
        }
    }
    return orders;
}

private List<Order> deal(Order fstOrder, Order scdOrder) {
    List<Order> ordersForDelete = new LinkedList<>();
    if (dealIsImpossible(fstOrder, scdOrder)) {
        return ordersForDelete;
    }

    if (fstOrder.getVolume() < scdOrder.getVolume()) {
        int volume = scdOrder.getVolume() - fstOrder.getVolume();
        scdOrder.setVolume(volume);
        ordersForDelete.add(fstOrder);
    } else if (fstOrder.getVolume() > scdOrder.getVolume()) {
        int volume = fstOrder.getVolume() - scdOrder.getVolume();
        fstOrder.setVolume(volume);
        ordersForDelete.add(scdOrder);
    } else if (fstOrder.getVolume() == scdOrder.getVolume()) {
        ordersForDelete.add(fstOrder);
        ordersForDelete.add(scdOrder);
    }
    return ordersForDelete;
}
2
  • Нельзя делать операцию remove в коллекции, по которой вы итерируете. По этой причине у вас возникает либо ConcurrentModificationException (ошибка в итераторе), либо логическая ошибка в коде. Когда вы удалите элемент, у вас orders.size() изменится, и вы будете пропускать некоторые элементы.
    – iksuy
    7 мар 2017 в 14:32
  • 1
    не очень понял зачем хранить разницу getVolume(), в одном элементе и удалять другой. на мой взгляд легче быстрее создавать другой массив и добавлять туда новые элементы 7 мар 2017 в 14:43

1 ответ 1

1

как я понял, нужна операция distinct по особому полю. Это можно выполнить с помощью java 8 stream api с реализацией своего предиката.

public class Order {

    private int volume;
    private int sec;

    public Order(int volume) {
        this.volume = volume;
    }

    public int getVolume() {
        return volume;
    }

    @Override
    public String toString() {
        return "Order{" +
               "volume=" + volume +
               '}';
    }
}


public static void main(String[] args) {
    List<Order> collect = new ArrayList<Order>() {{
        add(new Order(4));
        add(new Order(1));
        add(new Order(1));
        add(new Order(8));
        add(new Order(1));
        add(new Order(2));
    }};

    List<Order> res = collect.stream().filter(distinctByKey(f -> f.getVolume())).collect(Collectors.toList());
    res.forEach(System.out::println);

}

public static <T> Predicate<T> distinctByKey(Function<? super T, ?> keyExtractor) {
    Map<Object,Boolean> seen = new ConcurrentHashMap<>();
    return t -> seen.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;
}

результат выполнения:

Order{volume=4}
Order{volume=1}
Order{volume=8}
Order{volume=2}

P.s можно использовать parallel() для ускорения операций

вдохновился источником

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.