package me.sup2is;

public class ClientReservation {
    private String from;
    private String to;

	//AllArgConstructor, Getter ...
}

package me.sup2is;

public class AirlineTicketInfo {

    private String airline;
    private ClientReservation clientReservation;
    private String departureTime;
    private String arrivalTime;
    private int price;

    private AirlineTicketInfo(){}

    public static AirlineTicketInfo createAirlineTicketInfo(String airline, ClientReservation clientReservation, String departureTime, String arrivalTime) {
        AirlineTicketInfo info = new AirlineTicketInfo();
        info.airline = airline;
        info.clientReservation = clientReservation;
        info.departureTime = departureTime;
        info.arrivalTime = arrivalTime;
        return info;
    }

    public void assignPrice(int price) {
        this.price = price;
    }

    
    //Getter ...
}

package me.sup2is;

public class AirlineService {

    public AirlineTicketInfo createTickerByAirline(String airline, ClientReservation reservation) {

        //항공사 서비스를 호출해서 티켓정보를 받아오는 로직 ...
        delay();
        
        AirlineTicketInfo airlineTicketInfo =
                AirlineTicketInfo.createAirlineTicketInfo(airline,
                                                            reservation,
                                                            "2020-16-18 09:00",
                                                            "2020-16-18 10:00");
        return airlineTicketInfo;
    }

    private String getRandomTime() {
        return "2020-16-18 "
                + String.format("%02d", random.nextInt(22) + 1)
                + ":"
                + String.format("%02d", random.nextInt(58) + 1);
    }

    
    public void delay () {
        try {
            Thread.sleep(1000);
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

}

public static void main(String[] args) {

    List<String> airlines = Arrays.asList("Qatar Airways", "Singapore Airlines" ...... ); //32개의 항공사
    
    long start = System.currentTimeMillis();
    List<AirlineTicketInfo> collect = airlines.stream()
        .map(airline -> airlineService.createTickerByAirline(airline, reservation))
        .collect(Collectors.toList());

    long end = System.currentTimeMillis();
    print(collect);
    System.out.println("티켓정보를 가져오는데 걸린 시간: " + (end - start) + "ms");
    
}

public static void main(String[] args) {

    List<String> airlines = Arrays.asList("Qatar Airways", "Singapore Airlines" ...... ); //32개의 항공사
    
    long start = System.currentTimeMillis();
    
    List<AirlineTicketInfo> collect = airlines.parallelStream()
        .map(airline -> airlineService.createTickerByAirline(airline, reservation))
        .collect(Collectors.toList());
    
    long end = System.currentTimeMillis();
    print(collect);
    System.out.println("티켓정보를 가져오는데 걸린 시간: " + (end - start) + "ms");
    
}

public static void main(String[] args) {

    List<String> airlines = Arrays.asList("Qatar Airways", "Singapore Airlines" ...... ); //32개의 항공사
    
    long start = System.currentTimeMillis();
    
    List<CompletableFuture<AirlineTicketInfo>> reservationInfos = airlines.stream()
        .map(airline -> CompletableFuture.supplyAsync(() -> airlineService.createTickerByAirline(airline, reservation)))
        .collect(Collectors.toList());
    List<AirlineTicketInfo> collect = reservationInfos.stream().map(CompletableFuture::join).collect(Collectors.toList());
    
    long end = System.currentTimeMillis();
    print(collect);
    System.out.println("티켓정보를 가져오는데 걸린 시간: " + (end - start) + "ms");
    
}

public static void main(String[] args) {

    List<String> airlines = Arrays.asList("Qatar Airways", "Singapore Airlines" ...... ); //32개의 항공사
    
    long start = System.currentTimeMillis();
        
    Executor executor = Executors.newFixedThreadPool(Math.min(airlines.size(), 100), r -> {
        Thread t = new Thread(r);
        t.setDaemon(true);
        return t;
    });

    List<CompletableFuture<AirlineTicketInfo>> reservationInfos = airlines.stream()
        .map(airline -> CompletableFuture.supplyAsync(() -> airlineService.createTickerByAirline(airline, reservation), executor))
        .collect(Collectors.toList());
    List<AirlineTicketInfo> collect = reservationInfos.stream().map(CompletableFuture::join).collect(Collectors.toList());
    
    long end = System.currentTimeMillis();
    print(collect);
    System.out.println("티켓정보를 가져오는데 걸린 시간: " + (end - start) + "ms");
    
}
        

package me.sup2is;

public class SellerService {

    public AirlineTicketInfo assignPrice(AirlineTicketInfo airlineTicketInfo) {
        
        //판매자에게 해당 티켓의 최저가를 가져오는 로직 ...
        delay();
        airlineTicketInfo.assignPrice(100_000);
        return airlineTicketInfo;
    }

    public void delay () {
        try {
            Thread.sleep(1000);
        }catch (Exception e) {
            e.printStackTrace();
        }
    }
}

public static void main(String[] args) {

    List<String> airlines = Arrays.asList("Qatar Airways", "Singapore Airlines" ...... ); //32개의 항공사
    
    long start = System.currentTimeMillis();
        
    Executor executor = Executors.newFixedThreadPool(Math.min(airlines.size(), 100), r -> {
        Thread t = new Thread(r);
        t.setDaemon(true);
        return t;
    });

    List<CompletableFuture<AirlineTicketInfo>> reservationInfos = airlines.stream()
        .map(airline -> CompletableFuture.supplyAsync(() -> airlineService.createTickerByAirline(airline, reservation), executor))
        .map(future -> future.thenCompose(airlineTicketInfo -> CompletableFuture.supplyAsync(() 
                                                                                             -> sellerService.assignPrice(airlineTicketInfo), executor)))
        .collect(Collectors.toList());
    List<AirlineTicketInfo> collect = reservationInfos.stream().map(CompletableFuture::join).collect(Collectors.toList());

    
    long end = System.currentTimeMillis();
    print(collect);
    System.out.println("티켓정보를 가져오는데 걸린 시간: " + (end - start) + "ms");
    
}