/**

 *

 * @author zhangy6

 * <p>对比Stream、parallelStream</p>

 * @date 2017-07-25

 */

public class StreamTest {

    public static void main(String[] args) {

        String path = "pku_training.utf8";

        try {

            List<String> list = IOUtil.readFile2List(path, "utf-8");

            long start = System.currentTimeMillis();

            list.stream().

            filter(e -> StringUtils.isNotBlank(e)).

            map(e -> getIdiom(e)).

            collect(Collectors.toList());

            System.out.println("stream : " + (System.currentTimeMillis() - start) + "ms");

            start = System.currentTimeMillis();

            list.parallelStream().

            filter(e -> StringUtils.isNotBlank(e)).

            map(e -> getIdiom(e)).

            collect(Collectors.toList());

            System.out.println("parallelStream : " + (System.currentTimeMillis() - start) + "ms");

        } catch (UnsupportedEncodingException e) {

            e.printStackTrace();

        } catch (FileNotFoundException e) {

            e.printStackTrace();

        }

    }

    private static List<String> getIdiom(String string) {

        String[] array = string.split("\\s+");

        List<String> list = Arrays.asList(array);

        return list.stream().filter(e -> e.length() == 4).collect(Collectors.toList());

    }

}

stream : 317ms

parallelStream : 90ms