sunels

import redis.clients.jedis.Jedis;

import java.util.List;
import java.util.Random;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class RedisQueueConsumer {
    public static void main(String[] args) {

sunels

import redis.clients.jedis.Jedis;

import java.util.Scanner;

public class RedisQueueProducer {
    public static void main(String[] args) {

        Jedis jedis = new Jedis("localhost");
        Scanner scanIn = new Scanner(System.in);

sunels

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class CompletableFutureTimeoutUnEfficientWay {

sunels

package com.company;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

/**

sunels

package com.company.samples;


import java.util.*;
import java.util.function.BinaryOperator;
import java.util.function.Function;
import java.util.stream.Collectors;

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

sunels

        Worker w1 = new Worker ("w1", 181, 81);
        Worker w2 = new Worker ("w2", 182, 82);
        Worker w3 = new Worker ("w3", 183, 83);
        Worker w4 = null;
        Worker w5 = new Worker ("w5", 185, 85);

        List<Optional<Worker>> workerList = new ArrayList<> ();
        workerList.add (Optional.ofNullable (w1));
        workerList.add (Optional.ofNullable (w2));
        workerList.add (Optional.ofNullable (w3));

sunels

package com.company.samples.optional;

import com.company.samples.way10.Worker;

import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Optional;

/**

sunels

Predicate<T>-- T in ,boolean out
Predicate<Man> richManMatcher = m->m.getCashAmount ()  > 1000000;
if (richManMatcher.test (someMan)) { 
       marryWithRichMan (someMan);
}

Function<T,R> -- Tin, R out
Function<Worker,Integer> salaryIncreaser = w->w.getSalary () + 500;
for (Worker worker: workers){
       worker.setSalary (salaryIncreaser.apply(worker));

sunels

StateManager stateManager = new StateManager();

stateManager.addNewStateListener(
    (oldState, newState) -> System.out.println("State changed")
);

sunels

public class StateManager {
    public void addNewStateListener(StateChangeListener listener) { //blahh }
}