Thanks for your help.  FYI: https://issues.apache.org/jira/browse/JCR-3194


On 12/23/2011 03:49 PM, Stefan Guggisberg wrote:
> package test;
> >>>
> >>>  import java.io.File;
> >>>  import java.util.concurrent.ExecutorService;
> >>>  import java.util.concurrent.Executors;
> >>>  import java.util.concurrent.TimeUnit;
> >>>  import java.util.concurrent.atomic.AtomicBoolean;
> >>>  import java.util.concurrent.atomic.AtomicInteger;
> >>>
> >>>  import javax.jcr.Repository;
> >>>  import javax.jcr.RepositoryException;
> >>>  import javax.jcr.Session;
> >>>  import javax.jcr.SimpleCredentials;
> >>>
> >>>  import org.apache.jackrabbit.core.TransientRepository;
> >>>
> >>>  public class JackrabbitTest {
> >>>
> >>>    public static void main(final String[] args) throws Exception {
> >>>      File dir = File.createTempFile("jackrabbit-test", "");
> >>>      dir.delete();
> >>>      dir.mkdir();
> >>>      System.out.println("created temporary directory: " +
> >>>          dir.getAbsolutePath());
> >>>      dir.deleteOnExit();
> >>>
> >>>      final Repository jcrRepo = new TransientRepository(dir);
> >>>      final AtomicBoolean passed = new AtomicBoolean(true);
> >>>      final AtomicInteger counter = new AtomicInteger(0);
> >>>      ExecutorService executor = Executors.newFixedThreadPool(50);
> >>>      Runnable runnable = new Runnable() {
> >>>
> >>>        @Override
> >>>        public void run() {
> >>>          try {
> >>>            Session session = jcrRepo.login(
> >>>                new SimpleCredentials("admin",
> >>>                    "admin".toCharArray()));
> >>>            session.getRootNode().addNode("n" +
> >>>                    counter.getAndIncrement()); //unique name
> >>>            session.save();
> >>>            session.logout();
> >>>          } catch (RepositoryException e) {
> >>>            e.printStackTrace();
> >>>            passed.set(false);
> >>>          }
> >>>        }
> >>>
> >>>      };
> >>>      System.out.println("Running threads");
> >>>      for (int i = 0; i<   500; i++) {
> >>>        executor.execute(runnable);
> >>>      }
> >>>      executor.shutdown(); //Disable new tasks from being submitted
> >>>      if (!executor.awaitTermination(120, TimeUnit.SECONDS)) {
> >>>        System.err.println("timeout");
> >>>        System.exit(1);
> >>>      }
> >>>      if (!passed.get()) {
> >>>        System.err.println("one or more threads got an exception");
> >>>        System.exit(1);
> >>>      } else {
> >>>        System.out.println("all threads ran with no exceptions");
> >>>        System.exit(0);
> >>>      }
> >>>
> >>>    }
> >>>
> >>>  }