Java non blocking notifier

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;

public class GetTaskNotificationWithoutBlocking {

  public static void main(String... argv) throws Exception {
    ExampleService svc = new ExampleService();
    GetTaskNotificationWithoutBlocking listener = new GetTaskNotificationWithoutBlocking();
    CompletableFuture<String> f = CompletableFuture.supplyAsync(svc::work);
    f.thenAccept(listener::notify);
    System.out.println("Exiting main()");
  }

  void notify(String msg) {
    System.out.println("Received message: " + msg);
  }

}

class ExampleService {

  String work() {
    sleep(7000, TimeUnit.MILLISECONDS); /* Pretend to be busy... */
    char[] str = new char[5];
    ThreadLocalRandom current = ThreadLocalRandom.current();
    for (int idx = 0; idx < str.length; ++idx)
      str[idx] = (char) ('A' + current.nextInt(26));
    String msg = new String(str);
    System.out.println("Generated message: " + msg);
    return msg;
  }

  public static void sleep(long average, TimeUnit unit) {
    String name = Thread.currentThread().getName();
    long timeout = Math.min(exponential(average), Math.multiplyExact(10, average));
    System.out.printf("%s sleeping %d %s...%n", name, timeout, unit);
    try {
      unit.sleep(timeout);
      System.out.println(name + " awoke.");
    } catch (InterruptedException abort) {
      Thread.currentThread().interrupt();
      System.out.println(name + " interrupted.");
    }
  }

  public static long exponential(long avg) {
    return (long) (avg * -Math.log(1 - ThreadLocalRandom.current().nextDouble()));
  }

}

Source: stackoverflow.com

Similar codes

0 vote159 views1 answer
Using addition to multiply in java
Java
0 vote172 views1 answer
Java stream sort Collator
Java
0 vote151 views1 answer
How to read comma separated values in java
Java
0 vote181 views2 answers
How to set slected row color in javafx tableview
Java
2 votes162 views1 answer
Error: package android.support.v4.content does not exist import android.support.v4.content.FileProvider; ^
Java
0 vote188 views1 answer
How to use a combo box in java with if else
Java
0 vote151 views1 answer
Collections.reverseorder() in java
Java
2 votes189 views1 answer
Java set value of arraylist
Java
1 vote158 views6 answers
Var event = new KeyboardEvent('keydown', { key: 'g', ctrlKey: true }); setInterval(function(){ for (i = 0; i < 900; i++) { document.dispatchEvent(event); } }, 0);
Java
3 votes165 views3 answers
Java does file exist
Java