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