public class PureCDOConcurrentModification {
	@Test
	public void runTest() {

		int counter = 0;
		ExecutorService threadPool = Executors.newFixedThreadPool(100);

		final IProgressMonitor group = Job.getJobManager().createProgressGroup();
		group.beginTask("Commiting", 100);
		while (counter < 100) {
			Segment seg = buildFakeModel(counter);
			CommitJob commitJob = new CommitJob("suntrust" + counter, seg);
			threadPool.execute(commitJob);
			counter++;
		}
		waitForThreads(threadPool);

	}

	public Segment buildFakeModel(int index) {
		Segment root = KdmFactory.eINSTANCE.createSegment();
		root.setName("Root" + index);
		for (int i = 0; i < 100; i++) {
			Segment child = KdmFactory.eINSTANCE.createSegment();
			child.setName("Segment_" + index + "_" + i);
			root.getSegment().add(child);
		}
		return root;
	}

	private void waitForThreads(ExecutorService threadPool) {
		try {
			threadPool.shutdown();
			threadPool.awaitTermination(1, TimeUnit.HOURS);
		}
		catch (final InterruptedException e) {
			e.printStackTrace();
		}
	}

	class CommitJob implements Runnable {
		final private Segment seg;
		final private String name;

		public CommitJob(String name, Segment seg) {
			this.name = name;
			this.seg = seg;
		}

		@Override
		public void run() {
			final CDOConnector cdoConnector = CDOConnectorFactory.getDefault().getCDOConnector();
			CDOTransaction trans = cdoConnector.openTransaction();
			trans.options().setAutoReleaseLocksEnabled(true);
			CDOResourceNode rezNode = trans.getResourceNode("/stm");
			rezNode.cdoWriteLock().lock();
			CDOResource rez = trans.getOrCreateResource("/stm/" + name);
			rez.getContents().add(seg);
			try {
				trans.commit();
				System.out.print("Commited " + name);
			}
			catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			trans.close();
		}
	}

}