提交 d79701c5 编写于 作者: A amlu

8148928: java/util/stream/test/**/SequentialOpTest.java timed out intermittently

Reviewed-by: psandoz
Contributed-by: huaming.li@oracle.com
上级 6c68010f
...@@ -47,6 +47,7 @@ public class StreamTestDataProvider { ...@@ -47,6 +47,7 @@ public class StreamTestDataProvider {
private static final Object[][] testData; private static final Object[][] testData;
private static final Object[][] testSmallData; private static final Object[][] testSmallData;
private static final Object[][] testMiniData;
private static final Object[][] withNullTestData; private static final Object[][] withNullTestData;
private static final Object[][] spliteratorTestData; private static final Object[][] spliteratorTestData;
...@@ -85,6 +86,7 @@ public class StreamTestDataProvider { ...@@ -85,6 +86,7 @@ public class StreamTestDataProvider {
static { static {
{ {
List<Object[]> listMini = new ArrayList<>();
List<Object[]> listSmall = new ArrayList<>(); List<Object[]> listSmall = new ArrayList<>();
List<Object[]> list1000 = new ArrayList<>(); List<Object[]> list1000 = new ArrayList<>();
List<Object[]> list = null; List<Object[]> list = null;
...@@ -93,7 +95,7 @@ public class StreamTestDataProvider { ...@@ -93,7 +95,7 @@ public class StreamTestDataProvider {
final Integer[] ints = (Integer[])data[1]; final Integer[] ints = (Integer[])data[1];
final List<Integer> intsAsList = Arrays.asList(ints); final List<Integer> intsAsList = Arrays.asList(ints);
list = ints.length >= 1000 ? list1000 : listSmall; list = ints.length >= 1000 ? list1000 : (ints.length >= 100 ? listSmall : listMini);
list.add(arrayDataDescr("array:" + name, ints)); list.add(arrayDataDescr("array:" + name, ints));
list.add(collectionDataDescr("ArrayList.asList:" + name, intsAsList)); list.add(collectionDataDescr("ArrayList.asList:" + name, intsAsList));
...@@ -119,6 +121,8 @@ public class StreamTestDataProvider { ...@@ -119,6 +121,8 @@ public class StreamTestDataProvider {
// @@@ Add more // @@@ Add more
} }
testMiniData = listMini.toArray(new Object[0][]);
listSmall.addAll(listMini);
testSmallData = listSmall.toArray(new Object[0][]); testSmallData = listSmall.toArray(new Object[0][]);
list1000.addAll(listSmall); list1000.addAll(listSmall);
testData = list1000.toArray(new Object[0][]); testData = list1000.toArray(new Object[0][]);
...@@ -204,6 +208,11 @@ public class StreamTestDataProvider { ...@@ -204,6 +208,11 @@ public class StreamTestDataProvider {
return testSmallData; return testSmallData;
} }
@DataProvider(name = "StreamTestData<Integer>.mini")
public static Object[][] makeMiniStreamTestData() {
return testMiniData;
}
@DataProvider(name = "withNull:StreamTestData<Integer>") @DataProvider(name = "withNull:StreamTestData<Integer>")
public static Object[][] makeStreamWithNullTestData() { public static Object[][] makeStreamWithNullTestData() {
return withNullTestData; return withNullTestData;
......
/* /*
* Copyright (c) 2012, 2013, Oracle and/or its affiliates. All rights reserved. * Copyright (c) 2012, 2016, Oracle and/or its affiliates. All rights reserved.
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
* *
* This code is free software; you can redistribute it and/or modify it * This code is free software; you can redistribute it and/or modify it
...@@ -94,7 +94,7 @@ public class SequentialOpTest extends OpTestCase { ...@@ -94,7 +94,7 @@ public class SequentialOpTest extends OpTestCase {
} }
@SuppressWarnings({"rawtypes", "unchecked"}) @SuppressWarnings({"rawtypes", "unchecked"})
@Test(dataProvider = "StreamTestData<Integer>", dataProviderClass = StreamTestDataProvider.class) @Test(dataProvider = "StreamTestData<Integer>.mini", dataProviderClass = StreamTestDataProvider.class)
public void testMixedSeqPar(String name, TestData.OfRef<Integer> data) { public void testMixedSeqPar(String name, TestData.OfRef<Integer> data) {
Function<Integer, Integer> id = LambdaTestHelpers.identity(); Function<Integer, Integer> id = LambdaTestHelpers.identity();
UnaryOperator<Stream<Integer>>[] changers UnaryOperator<Stream<Integer>>[] changers
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册