2 * Copyright 2005 the original author or authors.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 package org.wamblee.concurrency;
19 import org.wamblee.test.EventTracker;
20 import org.wamblee.test.TimingUtils;
22 import junit.framework.TestCase;
25 * Tests for the JVMLock.
27 public class JvmLockTest extends TestCase {
29 private static final int SLEEP_TIME = 1000;
31 private static final String STARTED = "started";
33 private static final String ACQUIRED = "acquired";
35 private static final String RELEASED = "released";
37 private JvmLock _lock;
39 private EventTracker<String> _tracker;
44 * @see junit.framework.TestCase#setUp()
47 protected void setUp() throws Exception {
48 _lock = new JvmLock();
49 _tracker = new EventTracker<String>();
52 private Thread runThread() {
53 Thread t = new Thread(new Runnable() {
55 _tracker.eventOccurred(STARTED);
57 _tracker.eventOccurred(ACQUIRED);
58 TimingUtils.sleep(SLEEP_TIME);
60 _tracker.eventOccurred(RELEASED);
68 * Tests the operation of the lock.
70 public void testLock() throws InterruptedException {
71 Thread t1 = runThread();
72 Thread t2 = runThread();
73 TimingUtils.sleep(SLEEP_TIME / 10); // give threads a chance to start
75 assertEquals(2, _tracker.getEventCount(STARTED)); // both threads
78 assertEquals(1, _tracker.getEventCount(ACQUIRED)); // one thread has
81 TimingUtils.sleep(SLEEP_TIME);
82 assertEquals(2, _tracker.getEventCount(ACQUIRED)); // now the other
85 assertEquals(1, _tracker.getEventCount(RELEASED)); // and the first
88 TimingUtils.sleep(SLEEP_TIME);
89 assertEquals(2, _tracker.getEventCount(RELEASED)); // both threads