Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat (limited to 'common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/command/QueueingExtendedCommandExecutor.java')
-rw-r--r--common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/command/QueueingExtendedCommandExecutor.java83
1 files changed, 0 insertions, 83 deletions
diff --git a/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/command/QueueingExtendedCommandExecutor.java b/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/command/QueueingExtendedCommandExecutor.java
deleted file mode 100644
index b030ed4175..0000000000
--- a/common/plugins/org.eclipse.jpt.common.utility/src/org/eclipse/jpt/common/utility/internal/command/QueueingExtendedCommandExecutor.java
+++ /dev/null
@@ -1,83 +0,0 @@
-/*******************************************************************************
- * Copyright (c) 2012 Oracle. All rights reserved.
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0, which accompanies this distribution
- * and is available at http://www.eclipse.org/legal/epl-v10.html.
- *
- * Contributors:
- * Oracle - initial API and implementation
- ******************************************************************************/
-package org.eclipse.jpt.common.utility.internal.command;
-
-import org.eclipse.jpt.common.utility.command.Command;
-import org.eclipse.jpt.common.utility.command.ExtendedCommandExecutor;
-import org.eclipse.jpt.common.utility.command.StatefulExtendedCommandExecutor;
-
-/**
- * Calls to {@link #waitToExecute(Command)} will suspend the current thread
- * until the command executor is {@link #start() started} and any previously-
- * dispatched commands have executed.
- *
- * @see AbstractQueueingCommandExecutor
- */
-public class QueueingExtendedCommandExecutor
- extends AbstractQueueingCommandExecutor<StatefulExtendedCommandExecutor>
- implements StatefulExtendedCommandExecutor
-{
- public QueueingExtendedCommandExecutor() {
- this(ExtendedCommandExecutor.Default.instance());
- }
-
- public QueueingExtendedCommandExecutor(ExtendedCommandExecutor commandExecutor) {
- this(new SimpleStatefulExtendedCommandExecutor(commandExecutor));
- }
-
- public QueueingExtendedCommandExecutor(StatefulExtendedCommandExecutor commandExecutor) {
- super(commandExecutor);
- }
-
- /**
- * Suspend the current thread until the command executor is
- * {@link #start() started}.
- */
- public void waitToExecute(Command command) throws InterruptedException {
- SynchronizingCommand syncCommand = new SynchronizingCommand();
-
- this.execute(syncCommand); // put the sync command on the queue and wait until it has executed
-
- try {
- syncCommand.waitForExecution();
- this.commandExecutor.waitToExecute(command);
- } finally {
- syncCommand.release();
- }
- }
-
- /**
- * Wait until all the commands currently on the queue have been executed,
- * then execute the specified command. Suspend the command-executing thread
- * while we execute the specified command.
- */
- public boolean waitToExecute(Command command, long timeout) throws InterruptedException {
- if (timeout == 0L) {
- this.waitToExecute(command);
- return true;
- }
-
- long stop = System.currentTimeMillis() + timeout;
- SynchronizingCommand syncCommand = new SynchronizingCommand();
-
- this.execute(syncCommand); // dispatch the sync command to the other thread
-
- try {
- if (syncCommand.waitForExecution(timeout)) {
- // adjust the time
- timeout = stop - System.currentTimeMillis();
- return (timeout > 0) && this.commandExecutor.waitToExecute(command, timeout);
- }
- return false;
- } finally {
- syncCommand.release();
- }
- }
-}

Back to the top