ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/AbstractQueuedSynchronizerTest.java
(Generate patch)

Comparing jsr166/src/test/tck/AbstractQueuedSynchronizerTest.java (file contents):
Revision 1.9 by dl, Wed Jan 7 01:02:17 2004 UTC vs.
Revision 1.11 by dl, Thu Jan 8 01:29:46 2004 UTC

# Line 73 | Line 73 | public class AbstractQueuedSynchronizerT
73          public boolean isLocked() { return sync.isLocked(); }
74          public boolean hasQueuedThreads() { return sync.hasQueuedThreads(); }
75          public boolean hasContended() { return sync.hasContended(); }
76 +        public boolean isQueued(Thread t) { return sync.isQueued(t); }
77      }
78  
79      /**
# Line 149 | Line 150 | public class AbstractQueuedSynchronizerT
150              t1.join();
151              t2.join();
152          } catch(Exception e){
153 +            unexpectedException();
154 +        }
155 +    }
156 +
157 +    /**
158 +     * isQueued(null) throws NPE
159 +     */
160 +    public void testIsQueuedNPE() {
161 +        final Mutex lock = new Mutex();
162 +        try {
163 +            lock.isQueued(null);
164 +            shouldThrow();
165 +        } catch (NullPointerException success) {
166 +        }
167 +    }
168 +
169 +    /**
170 +     * isQueued reports whether a thread is queued.
171 +     */
172 +    public void testIsQueued() {
173 +        final Mutex lock = new Mutex();
174 +        Thread t1 = new Thread(new InterruptedLockRunnable(lock));
175 +        Thread t2 = new Thread(new InterruptibleLockRunnable(lock));
176 +        try {
177 +            assertFalse(lock.isQueued(t1));
178 +            assertFalse(lock.isQueued(t2));
179 +            lock.lock();
180 +            t1.start();
181 +            Thread.sleep(SHORT_DELAY_MS);
182 +            assertTrue(lock.isQueued(t1));
183 +            t2.start();
184 +            Thread.sleep(SHORT_DELAY_MS);
185 +            assertTrue(lock.isQueued(t1));
186 +            assertTrue(lock.isQueued(t2));
187 +            t1.interrupt();
188 +            Thread.sleep(SHORT_DELAY_MS);
189 +            assertFalse(lock.isQueued(t1));
190 +            assertTrue(lock.isQueued(t2));
191 +            lock.unlock();
192 +            Thread.sleep(SHORT_DELAY_MS);
193 +            assertFalse(lock.isQueued(t1));
194 +            assertFalse(lock.isQueued(t2));
195 +            t1.join();
196 +            t2.join();
197 +        } catch(Exception e){
198              unexpectedException();
199          }
200      }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines