Stream系列(十四)parallet方法使用

package com.example.demo;

import lombok.extern.log4j.Log4j2;
import org.junit.Test;

import java.util.concurrent.TimeUnit;

@Log4j2
public class EmployeeTestCase extends BaseTestCase {
    @Test
    public void parallel(){
        list.stream().parallel().forEach(employee -> {
            cal(employee);
        });
    }
    private static void cal(Employee employee) {
        try {
            long lTime = Double.valueOf(employee.getSalary()).longValue();
            TimeUnit.MILLISECONDS.sleep(lTime);
            log.info("name:{}", employee.getName());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

package com.example.demo;

import java.util.Arrays;
import java.util.List;

public class BaseTestCase {
    protected static final List<Employee> list = Arrays.asList(
            new Employee(1, "Alex", 1000),
            new Employee(2, "Michael", 2000),
            new Employee(3, "Jack", 1500),
            new Employee(4, "Owen", 1500),
            new Employee(5, "Denny", 2000));
}

20:24:15.885 [ForkJoinPool.commonPool-worker-7] INFO com.example.demo.EmployeeTestCase - name:Alex
20:24:16.377 [main] INFO com.example.demo.EmployeeTestCase - name:Jack
20:24:16.378 [ForkJoinPool.commonPool-worker-9] INFO com.example.demo.EmployeeTestCase - name:Owen
20:24:16.878 [ForkJoinPool.commonPool-worker-3] INFO com.example.demo.EmployeeTestCase - name:Michael
20:24:16.878 [ForkJoinPool.commonPool-worker-5] INFO com.example.demo.EmployeeTestCase - name:Denny