iframe-proxy | Sunbelt Computer Software

39 lines (30 loc) · 1.18 KB

package com.javatechie;

import java.util.concurrent.CompletableFuture;

import java.util.function.IntPredicate;

import java.util.stream.IntStream;

public class EvenAndOddPrinter {

private static Object object = new Object();

private static IntPredicate evenCondition = e -> e % 2 == 0;

private static IntPredicate oddCondition = e -> e % 2 != 0;

public static void main(String[] args) throws InterruptedException {

CompletableFuture.runAsync(() -> EvenAndOddPrinter.printResults(oddCondition));

CompletableFuture.runAsync(() -> EvenAndOddPrinter.printResults(evenCondition));

Thread.sleep(1000);

}

public static void printResults(IntPredicate condition) {

IntStream.rangeClosed(1, 10)

.filter(condition)

.forEach(EvenAndOddPrinter::execute);

}

public static void execute(int i) {

synchronized (object) {

try {

System.out.println("Thread Name " + Thread.currentThread().getName() + " : " + i);

object.notify();

object.wait();

} catch (InterruptedException ex) {

//error log

}

Sunbelt Computer Software