Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package ch.claude_martin;
- import java.util.List;
- import java.util.Set;
- import java.util.concurrent.ConcurrentSkipListSet;
- import java.util.stream.Collectors;
- import java.util.stream.IntStream;
- public class SomeClass {
- public static void main(String[] args) {
- List<String> list2 = IntStream.range(0, 100000).parallel().mapToObj(i -> process(i))
- .collect(Collectors.toList());
- System.out.println(list2.subList(0, 30));
- System.out.println(THREAD_NAMES);
- }
- final static Set<String> THREAD_NAMES = new ConcurrentSkipListSet<>();
- /**
- * Absurd implementation!
- *
- * @returns "even" or "odd"
- */
- static String process(int i) {
- THREAD_NAMES.add(Thread.currentThread().getName());
- String binary = Integer.toBinaryString(i);
- while (binary.length() > 1)
- binary = binary.substring(1);
- return binary.charAt(binary.length() - 1) == '0' ? "even" : "odd";
- }
- }
Add Comment
Please, Sign In to add comment