ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/test/tck/ThreadLocalRandomTest.java

Comparing jsr166/src/test/tck/ThreadLocalRandomTest.java (file contents):
Revision 1.15 by dl, Wed Aug 14 12:41:18 2013 UTC vs.
Revision 1.19 by jsr166, Fri Sep 27 20:22:26 2013 UTC

#	Line 7 | Line 7 | import junit.framework.*;
7		import java.util.*;
8		import java.util.concurrent.ThreadLocalRandom;
9		import java.util.concurrent.atomic.AtomicLong;
10	–	import java.util.concurrent.atomic.AtomicInteger;
10		import java.util.concurrent.atomic.AtomicReference;
12	–	import java.util.concurrent.atomic.LongAdder;
11
12		public class ThreadLocalRandomTest extends JSR166TestCase {
13
#	Line 118 | Line 116 | public class ThreadLocalRandomTest exten
116		}
117
118		/**
119	<	* nextInt(negative) throws IllegalArgumentException
119	>	* nextInt(non-positive) throws IllegalArgumentException
120		*/
121	<	public void testNextIntBoundedNeg() {
122	<	try {
123	<	int f = ThreadLocalRandom.current().nextInt(-17);
124	<	shouldThrow();
125	<	} catch (IllegalArgumentException success) {}
121	>	public void testNextIntBoundNonPositive() {
122	>	ThreadLocalRandom rnd = ThreadLocalRandom.current();
123	>	for (int bound : new int[] { 0, -17, Integer.MIN_VALUE }) {
124	>	try {
125	>	rnd.nextInt(bound);
126	>	shouldThrow();
127	>	} catch (IllegalArgumentException success) {}
128	>	}
129		}
130
131		/**
132		* nextInt(least >= bound) throws IllegalArgumentException
133		*/
134		public void testNextIntBadBounds() {
135	<	try {
136	<	int f = ThreadLocalRandom.current().nextInt(17, 2);
137	<	shouldThrow();
138	<	} catch (IllegalArgumentException success) {}
135	>	int[][] badBoundss = {
136	>	{ 17, 2 },
137	>	{ -42, -42 },
138	>	{ Integer.MAX_VALUE, Integer.MIN_VALUE },
139	>	};
140	>	ThreadLocalRandom rnd = ThreadLocalRandom.current();
141	>	for (int[] badBounds : badBoundss) {
142	>	try {
143	>	rnd.nextInt(badBounds[0], badBounds[1]);
144	>	shouldThrow();
145	>	} catch (IllegalArgumentException success) {}
146	>	}
147		}
148
149		/**
#	Line 179 | Line 188 | public class ThreadLocalRandomTest exten
188		}
189
190		/**
191	<	* nextLong(negative) throws IllegalArgumentException
191	>	* nextLong(non-positive) throws IllegalArgumentException
192		*/
193	<	public void testNextLongBoundedNeg() {
194	<	try {
195	<	long f = ThreadLocalRandom.current().nextLong(-17);
196	<	shouldThrow();
197	<	} catch (IllegalArgumentException success) {}
193	>	public void testNextLongBoundNonPositive() {
194	>	ThreadLocalRandom rnd = ThreadLocalRandom.current();
195	>	for (long bound : new long[] { 0L, -17L, Long.MIN_VALUE }) {
196	>	try {
197	>	rnd.nextLong(bound);
198	>	shouldThrow();
199	>	} catch (IllegalArgumentException success) {}
200	>	}
201		}
202
203		/**
204		* nextLong(least >= bound) throws IllegalArgumentException
205		*/
206		public void testNextLongBadBounds() {
207	<	try {
208	<	long f = ThreadLocalRandom.current().nextLong(17, 2);
209	<	shouldThrow();
210	<	} catch (IllegalArgumentException success) {}
207	>	long[][] badBoundss = {
208	>	{ 17L, 2L },
209	>	{ -42L, -42L },
210	>	{ Long.MAX_VALUE, Long.MIN_VALUE },
211	>	};
212	>	ThreadLocalRandom rnd = ThreadLocalRandom.current();
213	>	for (long[] badBounds : badBoundss) {
214	>	try {
215	>	rnd.nextLong(badBounds[0], badBounds[1]);
216	>	shouldThrow();
217	>	} catch (IllegalArgumentException success) {}
218	>	}
219		}
220
221		/**
#	Line 239 | Line 259 | public class ThreadLocalRandomTest exten
259		}
260
261		/**
262	+	* nextDouble(non-positive) throws IllegalArgumentException
263	+	*/
264	+	public void testNextDoubleBoundNonPositive() {
265	+	ThreadLocalRandom rnd = ThreadLocalRandom.current();
266	+	double[] badBounds = {
267	+	0.0d,
268	+	-17.0d,
269	+	-Double.MIN_VALUE,
270	+	Double.NEGATIVE_INFINITY,
271	+	Double.NaN,
272	+	};
273	+	for (double bound : badBounds) {
274	+	try {
275	+	rnd.nextDouble(bound);
276	+	shouldThrow();
277	+	} catch (IllegalArgumentException success) {}
278	+	}
279	+	}
280	+
281	+	/**
282		* nextDouble(least, bound) returns least <= value < bound;
283		* repeated calls produce at least two distinct results
284		*/
#	Line 272 | Line 312 | public class ThreadLocalRandomTest exten
312		long firstRand = 0;
313		ThreadLocalRandom firstThreadLocalRandom = null;
314
315	<	final CheckedRunnable getRandomState = new CheckedRunnable() {
315	>	Runnable getRandomState = new CheckedRunnable() {
316		public void realRun() {
317		ThreadLocalRandom current = ThreadLocalRandom.current();
318		assertSame(current, ThreadLocalRandom.current());
#	Line 296 | Line 336 | public class ThreadLocalRandomTest exten
336		fail("all threads generate the same pseudo-random sequence");
337		}
338
299	–	/**
300	–	* Invoking sized ints, long, doubles, with negative sizes throws
301	–	* IllegalArgumentException
302	–	*/
303	–	public void testBadStreamSize() {
304	–	ThreadLocalRandom r = ThreadLocalRandom.current();
305	–	try {
306	–	java.util.stream.IntStream x = r.ints(-1L);
307	–	shouldThrow();
308	–	} catch (IllegalArgumentException success) {}
309	–	try {
310	–	java.util.stream.IntStream x = r.ints(-1L, 2, 3);
311	–	shouldThrow();
312	–	} catch (IllegalArgumentException success) {}
313	–	try {
314	–	java.util.stream.LongStream x = r.longs(-1L);
315	–	shouldThrow();
316	–	} catch (IllegalArgumentException success) {}
317	–	try {
318	–	java.util.stream.LongStream x = r.longs(-1L, -1L, 1L);
319	–	shouldThrow();
320	–	} catch (IllegalArgumentException success) {}
321	–	try {
322	–	java.util.stream.DoubleStream x = r.doubles(-1L);
323	–	shouldThrow();
324	–	} catch (IllegalArgumentException success) {}
325	–	try {
326	–	java.util.stream.DoubleStream x = r.doubles(-1L, .5, .6);
327	–	shouldThrow();
328	–	} catch (IllegalArgumentException success) {}
329	–	}
330	–
331	–	/**
332	–	* Invoking bounded ints, long, doubles, with illegal bounds throws
333	–	* IllegalArgumentException
334	–	*/
335	–	public void testBadStreamBounds() {
336	–	ThreadLocalRandom r = ThreadLocalRandom.current();
337	–	try {
338	–	java.util.stream.IntStream x = r.ints(2, 1);
339	–	shouldThrow();
340	–	} catch (IllegalArgumentException success) {}
341	–	try {
342	–	java.util.stream.IntStream x = r.ints(10, 42, 42);
343	–	shouldThrow();
344	–	} catch (IllegalArgumentException success) {}
345	–	try {
346	–	java.util.stream.LongStream x = r.longs(-1L, -1L);
347	–	shouldThrow();
348	–	} catch (IllegalArgumentException success) {}
349	–	try {
350	–	java.util.stream.LongStream x = r.longs(10, 1L, -2L);
351	–	shouldThrow();
352	–	} catch (IllegalArgumentException success) {}
353	–	try {
354	–	java.util.stream.DoubleStream x = r.doubles(0.0, 0.0);
355	–	shouldThrow();
356	–	} catch (IllegalArgumentException success) {}
357	–	try {
358	–	java.util.stream.DoubleStream x = r.doubles(10, .5, .4);
359	–	shouldThrow();
360	–	} catch (IllegalArgumentException success) {}
361	–	}
362	–
363	–	/**
364	–	* A parallel sized stream of ints generates the given number of values
365	–	*/
366	–	public void testIntsCount() {
367	–	LongAdder counter = new LongAdder();
368	–	ThreadLocalRandom r = ThreadLocalRandom.current();
369	–	long size = 0;
370	–	for (int reps = 0; reps < REPS; ++reps) {
371	–	counter.reset();
372	–	r.ints(size).parallel().forEach(x -> {counter.increment();});
373	–	assertEquals(size, counter.sum());
374	–	size += 524959;
375	–	}
376	–	}
377	–
378	–	/**
379	–	* A parallel sized stream of longs generates the given number of values
380	–	*/
381	–	public void testLongsCount() {
382	–	LongAdder counter = new LongAdder();
383	–	ThreadLocalRandom r = ThreadLocalRandom.current();
384	–	long size = 0;
385	–	for (int reps = 0; reps < REPS; ++reps) {
386	–	counter.reset();
387	–	r.longs(size).parallel().forEach(x -> {counter.increment();});
388	–	assertEquals(size, counter.sum());
389	–	size += 524959;
390	–	}
391	–	}
392	–
393	–	/**
394	–	* A parallel sized stream of doubles generates the given number of values
395	–	*/
396	–	public void testDoublesCount() {
397	–	LongAdder counter = new LongAdder();
398	–	ThreadLocalRandom r = ThreadLocalRandom.current();
399	–	long size = 0;
400	–	for (int reps = 0; reps < REPS; ++reps) {
401	–	counter.reset();
402	–	r.doubles(size).parallel().forEach(x -> {counter.increment();});
403	–	assertEquals(size, counter.sum());
404	–	size += 524959;
405	–	}
406	–	}
407	–
408	–	/**
409	–	* Each of a parallel sized stream of bounded ints is within bounds
410	–	*/
411	–	public void testBoundedInts() {
412	–	AtomicInteger fails = new AtomicInteger(0);
413	–	ThreadLocalRandom r = ThreadLocalRandom.current();
414	–	long size = 12345L;
415	–	for (int least = -15485867; least < MAX_INT_BOUND; least += 524959) {
416	–	for (int bound = least + 2; bound > least && bound < MAX_INT_BOUND; bound += 67867967) {
417	–	final int lo = least, hi = bound;
418	–	r.ints(size, lo, hi).parallel().
419	–	forEach(x -> {if (x < lo || x >= hi)
420	–	fails.getAndIncrement(); });
421	–	}
422	–	}
423	–	assertEquals(0, fails.get());
424	–	}
425	–
426	–	/**
427	–	* Each of a parallel sized stream of bounded longs is within bounds
428	–	*/
429	–	public void testBoundedLongs() {
430	–	AtomicInteger fails = new AtomicInteger(0);
431	–	ThreadLocalRandom r = ThreadLocalRandom.current();
432	–	long size = 123L;
433	–	for (long least = -86028121; least < MAX_LONG_BOUND; least += 1982451653L) {
434	–	for (long bound = least + 2; bound > least && bound < MAX_LONG_BOUND; bound += Math.abs(bound * 7919)) {
435	–	final long lo = least, hi = bound;
436	–	r.longs(size, lo, hi).parallel().
437	–	forEach(x -> {if (x < lo || x >= hi)
438	–	fails.getAndIncrement(); });
439	–	}
440	–	}
441	–	assertEquals(0, fails.get());
442	–	}
443	–
444	–	/**
445	–	* Each of a parallel sized stream of bounded doubles is within bounds
446	–	*/
447	–	public void testBoundedDoubles() {
448	–	AtomicInteger fails = new AtomicInteger(0);
449	–	ThreadLocalRandom r = ThreadLocalRandom.current();
450	–	long size = 456;
451	–	for (double least = 0.00011; least < 1.0e20; least *= 9) {
452	–	for (double bound = least * 1.0011; bound < 1.0e20; bound *= 17) {
453	–	final double lo = least, hi = bound;
454	–	r.doubles(size, lo, hi).parallel().
455	–	forEach(x -> {if (x < lo || x >= hi)
456	–	fails.getAndIncrement(); });
457	–	}
458	–	}
459	–	assertEquals(0, fails.get());
460	–	}
461	–
462	–	/**
463	–	* A parallel unsized stream of ints generates at least 100 values
464	–	*/
465	–	public void testUnsizedIntsCount() {
466	–	LongAdder counter = new LongAdder();
467	–	ThreadLocalRandom r = ThreadLocalRandom.current();
468	–	long size = 100;
469	–	r.ints().limit(size).parallel().forEach(x -> {counter.increment();});
470	–	assertEquals(size, counter.sum());
471	–	}
472	–
473	–	/**
474	–	* A parallel unsized stream of longs generates at least 100 values
475	–	*/
476	–	public void testUnsizedLongsCount() {
477	–	LongAdder counter = new LongAdder();
478	–	ThreadLocalRandom r = ThreadLocalRandom.current();
479	–	long size = 100;
480	–	r.longs().limit(size).parallel().forEach(x -> {counter.increment();});
481	–	assertEquals(size, counter.sum());
482	–	}
483	–
484	–	/**
485	–	* A parallel unsized stream of doubles generates at least 100 values
486	–	*/
487	–	public void testUnsizedDoublesCount() {
488	–	LongAdder counter = new LongAdder();
489	–	ThreadLocalRandom r = ThreadLocalRandom.current();
490	–	long size = 100;
491	–	r.doubles().limit(size).parallel().forEach(x -> {counter.increment();});
492	–	assertEquals(size, counter.sum());
493	–	}
494	–
495	–	/**
496	–	* A sequential unsized stream of ints generates at least 100 values
497	–	*/
498	–	public void testUnsizedIntsCountSeq() {
499	–	LongAdder counter = new LongAdder();
500	–	ThreadLocalRandom r = ThreadLocalRandom.current();
501	–	long size = 100;
502	–	r.ints().limit(size).forEach(x -> {counter.increment();});
503	–	assertEquals(size, counter.sum());
504	–	}
505	–
506	–	/**
507	–	* A sequential unsized stream of longs generates at least 100 values
508	–	*/
509	–	public void testUnsizedLongsCountSeq() {
510	–	LongAdder counter = new LongAdder();
511	–	ThreadLocalRandom r = ThreadLocalRandom.current();
512	–	long size = 100;
513	–	r.longs().limit(size).forEach(x -> {counter.increment();});
514	–	assertEquals(size, counter.sum());
515	–	}
516	–
517	–	/**
518	–	* A sequential unsized stream of doubles generates at least 100 values
519	–	*/
520	–	public void testUnsizedDoublesCountSeq() {
521	–	LongAdder counter = new LongAdder();
522	–	ThreadLocalRandom r = ThreadLocalRandom.current();
523	–	long size = 100;
524	–	r.doubles().limit(size).forEach(x -> {counter.increment();});
525	–	assertEquals(size, counter.sum());
526	–	}
527	–
339		}

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines