tests/org.eclipse.core.tests.resources/src/org/eclipse/core/tests/resources/usecase/ConcurrencyTest.java

/*******************************************************************************
 * Copyright (c) 2000, 2002 IBM Corporation and others.
 * All rights reserved.   This program and the accompanying materials
 * are made available under the terms of the Common Public License v0.5
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/cpl-v05.html
 * 
 * Contributors:
 * IBM - Initial API and implementation
 ******************************************************************************/
package org.eclipse.core.tests.resources.usecase;

import org.eclipse.core.resources.*;
import org.eclipse.core.runtime.*;
import org.eclipse.core.tests.harness.EclipseWorkspaceTest;
import junit.framework.*;

public class ConcurrencyTest extends EclipseWorkspaceTest {
public ConcurrencyTest() {
}
public ConcurrencyTest(String name) {
	super(name);
}
protected void assertIsNotRunning(ConcurrentOperation01 op, String label) {
	/* try more than once, "just in case" */
	for (int i = 0; i < 3; i++) {
		try {
			Thread.sleep(100 * i); // fancy sleep
		} catch (InterruptedException e) {}
		assertTrue(label, !op.isRunning());
	}
}
public static Test suite() {
	return new TestSuite(ConcurrencyTest.class);
}
/**
 * This test is used to find out if two operations can start concurrently. It assumes
 * that they cannot.
 */
public void testConcurrentOperations() throws CoreException {

	IProject project = getWorkspace().getRoot().getProject("MyProject");
	project.create(null);
	project.open(null);

	buildResources(project, defineHierarchy());

	ConcurrentOperation01 op1 = new ConcurrentOperation01(getWorkspace());
	ConcurrentOperation01 op2 = new ConcurrentOperation01(getWorkspace());

	/* start first operation */
	new Thread(op1, "op1").start();
	assertTrue("0.0", op1.hasStarted());
	op1.returnWhenInSyncPoint();
	assertTrue("0.1", op1.isRunning());

	/* start second operation but it should not run until the first finishes */
	new Thread(op2, "op2").start();
	assertTrue("1.0", op2.hasStarted());
	assertIsNotRunning(op2, "1.1");

	/* free operations */
	op1.proceed();
	op2.returnWhenInSyncPoint();
	assertTrue("2.0", op2.isRunning());
	op2.proceed();
	assertTrue("2.1", op1.getStatus().isOK());
	assertTrue("2.2", op2.getStatus().isOK());

	/* remove trash */
	try {
		ensureDoesNotExistInWorkspace(getWorkspace().getRoot());
	} catch(Exception e){
	}
}
}