FilesExpand file tree

 master

/

ParallelPrime.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

35 lines (34 loc) · 1 KB

 master

/

ParallelPrime.java

Copy path

Top

File metadata and controls

• Code
• Blame

35 lines (34 loc) · 1 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

// concurrent/ParallelPrime.java

// (c)2021 MindView LLC: see Copyright.txt

// We make no guarantees that this code is fit for any purpose.

// Visit http://OnJava8.com for more book information.

import java.util.*;

import java.util.stream.*;

import static java.util.stream.LongStream.*;

import java.io.*;

import java.nio.file.*;

import onjava.Timer;

public class ParallelPrime {

static final int COUNT = 100_000;

public static boolean isPrime(long n) {

return rangeClosed(2, (long)Math.sqrt(n))

.noneMatch(i -> n % i == 0);

}

public static void main(String[] args)

throws IOException {

Timer timer = new Timer();

List<String> primes =

iterate(2, i -> i + 1)

.parallel() // [1]

.filter(ParallelPrime::isPrime)

.limit(COUNT)

.mapToObj(Long::toString)

.collect(Collectors.toList());

System.out.println(timer.duration());

Files.write(Paths.get("primes.txt"), primes,

StandardOpenOption.CREATE);

}

}

/* Output:

1635

*/