| | |
| | | * |
| | | * Copyright 2008-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2015-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC. |
| | | */ |
| | | package org.opends.guitools.controlpanel.browser; |
| | | |
| | |
| | | private final String name; |
| | | private final List<AbstractNodeTask> waitingQueue = new ArrayList<>(); |
| | | private final Map<BasicNode, AbstractNodeTask> workingList = new HashMap<>(); |
| | | private final Map<BasicNode, BasicNode> cancelList = new HashMap<>(); |
| | | private final ThreadGroup threadGroup; |
| | | |
| | | |
| | |
| | | // Mark the on-going task as cancelled |
| | | AbstractNodeTask task = workingList.get(node); |
| | | if (task != null) { |
| | | cancelList.put(node, node); |
| | | task.cancel(); |
| | | } |
| | | notify(); |
| | |
| | | waitingQueue.clear(); |
| | | for (Map.Entry<BasicNode, AbstractNodeTask> entry : workingList.entrySet()) |
| | | { |
| | | BasicNode node = entry.getKey(); |
| | | AbstractNodeTask task = entry.getValue(); |
| | | cancelList.put(node, node); |
| | | task.cancel(); |
| | | entry.getValue().cancel(); |
| | | } |
| | | } |
| | | |
| | |
| | | throw new IllegalArgumentException("null argument"); |
| | | } |
| | | workingList.remove(task.getNode()); |
| | | cancelList.remove(task.getNode()); |
| | | notify(); |
| | | // System.out.println("Flushed " + task + " from " + _name); |
| | | } |