728x90

1. @EnableAsync란 무엇인가?

@EnableAsync는 Spring에서 비동기 메서드를 활성화하기 위한 애너테이션입니다. 이를 통해 특정 메서드를 별도의 스레드에서 실행하도록 지정할 수 있습니다. 기본적으로 Spring은 단일 스레드에서 동기적으로 요청을 처리하지만, @EnableAsync를 사용하면 Spring이 비동기 작업을 위한 스레드 풀을 생성하고 이를 통해 작업을 병렬 처리합니다.

 

2. 기본 설정 방법

2.1. AsyncConfig 클래스 작성

@EnableAsync는 구성 클래스에 선언하여 사용합니다. 아래는 비동기 처리를 활성화하기 위한 간단한 설정 예제입니다.

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@Configuration
@EnableAsync
public class AsyncConfig {

    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);  // 기본 스레드 수
        executor.setMaxPoolSize(10); // 최대 스레드 수
        executor.setQueueCapacity(25); // 대기 중인 작업 큐의 크기
        executor.setThreadNamePrefix("AsyncExecutor-");
        executor.initialize();
        return executor;
    }
}

2.2. @Async 사용하기

@Async 애너테이션은 비동기로 실행할 메서드에 선언합니다. 해당 메서드는 별도의 스레드에서 실행됩니다.

예를 들어, 이메일을 비동기로 발송하는 기능을 구현해보겠습니다.

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class EmailService {

    @Async
    public void sendEmail(String recipient, String message) {
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

 

2.3. 비동기 메서드 호출 Controller 예제

@Async 애너테이션이 붙은 메서드는 호출 시 호출한 스레드와 별개의 스레드에서 실행됩니다. 이를 확인하기 위해 간단한 컨트롤러를 만들어보겠습니다.

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class EmailController {

    private final EmailService emailService;

    public EmailController(EmailService emailService) {
        this.emailService = emailService;
    }

    @GetMapping("/send-email")
    public String sendEmail() {
        emailService.sendEmail("user@example.com", "메일내용");
        return "메일 전송 완료";
    }
}

 

해당 컨트롤러를 호출해보면 sendEmail에서 3초 슬립을 걸어뒀지만 바로 리턴값 응답 받는걸 보실 수 있습니다.

'자바 JAVA' 카테고리의 다른 글

2. 자바 JAVA - 스트림(stream)  (0) 2023.04.05
1. 자바 JAVA - 스트림(stream)  (0) 2023.01.17
자바 JAVA - 람다 표현식  (0) 2023.01.14
자바 csv 파일쓰기 (한글깨짐 처리)  (1) 2021.09.14
728x90

앞서 이야기한 것처럼 자바 스트림(Stream)은 컬렉션 데이터를 함수형 프로그래밍 방식으로 처리할 수 있는 장점을 가지고 있습니다. 이번에는 스트림의 특징과 종류, 그리고 사용 방법 등에 대해 좀 더 자세히 살펴보겠습니다.

 

스트림의 특징

스트림은 크게 다음과 같은 특징을 가집니다.

  • 순차 처리(Stream)와 병렬 처리(Parallel Stream)를 모두 지원합니다.
  • 스트림은 데이터를 저장하지 않으며, 데이터를 처리하는 방식만을 정의합니다.
  • 스트림은 데이터 소스로부터 데이터를 읽기 때문에 한 번만 사용 가능합니다.
  • 중간 연산(intermediate operation)과 최종 연산(terminal operation)으로 구성됩니다.
  • 중간 연산은 스트림을 반환합니다. 즉, 중간 연산을 여러 개 연결하여 사용할 수 있습니다.
  • 최종 연산은 스트림을 종료하며, 스트림을 이용해 원하는 작업을 수행합니다.

스트림의 종류

스트림은 크게 세 가지 종류로 나눌 수 있습니다.

  • 기본형 스트림: int, long, double 등 기본형 데이터를 다루는 스트림입니다.
  • 객체 스트림: 객체를 다루는 스트림입니다.
  • 병렬 스트림: 여러 스레드를 이용해 병렬 처리를 할 수 있는 스트림입니다.

각 종류별로 제공되는 스트림의 메서드와 기능이 다르므로, 필요에 따라 적절한 스트림을 선택하여 사용해야 합니다.

스트림의 사용 방법

스트림은 컬렉션 데이터를 처리할 때 가장 많이 사용됩니다. 스트림은 다음과 같은 순서로 사용합니다.

  1. 컬렉션 데이터를 스트림으로 변환합니다.
  2. 중간 연산을 이용해 데이터를 처리합니다.
  3. 최종 연산을 이용해 최종 결과를 반환합니다.

스트림의 사용 예시를 보면 다음과 같습니다.

 

List<Integer> list = Arrays.asList(1, 2, 3, 4, 5);

int sum = list.stream()
              .filter(i -> i > 2)
              .mapToInt(i -> i * 2)
              .sum();
System.out.println(sum);

코드는 List 요소 중에서 2보다 요소를 2배로 만들어 합산한 값을 출력하는 예제입니다.

728x90

스트림이란?

자바의 스트림 또한 자바8부터 지원하는 문법으로 컬렉션 데이터를 for문 없이 함수형 프로그래밍을 할 수 있으며

병렬처리가 가능하단 장점이 있습니다.

 

사용법으로는 

arrayList.stream().filter().map().sorted() 이런식으로 사용할 수 있습니다.

 

위에서 보면 filter, map, sorted등 stream api에서 제공하는 여러 함수들이 있는데 함수들의 기능들을 알면 

필터링, 맵핑, 소팅, 출력등을 쉽게 제어할 수 있습니다.

아래 링크에 들어가면 함수별 기능이 있고, 필요에따라 사용하실 수 있습니다.

 

https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html 

 

Stream (Java Platform SE 8 )

A sequence of elements supporting sequential and parallel aggregate operations. The following example illustrates an aggregate operation using Stream and IntStream: int sum = widgets.stream() .filter(w -> w.getColor() == RED) .mapToInt(w -> w.getWeight())

docs.oracle.com

 

간단한 예제를 하나 보고 넘어가면 아래와 같이 String으로 구성된 ArrayList를 순서대로 출력을 할 수도 있고,

sorted()함수를 이용해 정렬 후 출력을 할 수 있습니다.

public class ArrayListStreamTest {
    public static void main(String[] args) {
        List<String> sList = new ArrayList<String>();
        sList.add("ddd");
        sList.add("bbb");
        sList.add("ccc");

        Stream<String> stream = sList.stream();
        stream.forEach(s-> System.out.println(s + " "));
        System.out.println();

        sList.stream().sorted().forEach(s-> System.out.println(s));
    }
}

또한 아래 예제처럼 int로 구성된 리스트중에서 filter()함수를 사용하여 리스트의 숫자중 3보다 큰수의 합만 구할 수도 있습니다.

public class intArraySum {
    public static void main(String[] args) {
        int[] arr = {1,2,3,4,5,6};

        int result = Arrays.stream(arr).filter(c -> c > 3).sum();
        System.out.println(result);
    }
}

 

728x90

람다란?

자바 8에서 새로 추가된 기능 중 하나인 람다(lambda)는 함수형 프로그래밍을 지원하며 코드의 간결성과 가독성을 높여주는 기능입니다. 이번 블로그에서는 자바 람다에 대해 간략하게 소개하고자 합니다.

  1. 람다 표현식 람다 표현식은 익명 함수를 만들기 위한 식으로, 메서드를 간단하게 표현할 수 있습니다. 람다 표현식은 세 가지 부분으로 이루어져 있습니다. 첫 번째는 매개변수 목록, 두 번째는 화살표(->), 그리고 세 번째는 메서드 바디입니다.

예를 들어, 다음과 같은 코드는 람다 표현식으로 간단하게 표현할 수 있습니다.

 

public class Example {
  public static void main(String[] args) {
    Runnable runnable = new Runnable() {
      public void run() {
        System.out.println("Hello, World!");
      }
    };
    runnable.run();
  }
}

 

위 코드를 람다 표현식으로 변경하면 다음과 같습니다.

public class Example {
  public static void main(String[] args) {
    Runnable runnable = () -> System.out.println("Hello, World!");
    runnable.run();
  }
}

2. 함수형 인터페이스 람다 표현식은 함수형 인터페이스(functional interface)를 구현할 때 사용됩니다. 함수형 인터페이스는 딱 하나의 추상 메서드만을 가지는 인터페이스로, 람다 표현식은 이 추상 메서드의 구현체를 만들어 줍니다.

예를 들어, 다음과 같은 코드는 Runnable 인터페이스를 구현한 클래스입니다.

 

public class Example {
  public static void main(String[] args) {
    Runnable runnable = new Runnable() {
      public void run() {
        System.out.println("Hello, World!");
      }
    };
    runnable.run();
  }
}

위 코드를 람다 표현식으로 변경하면 다음과 같습니다.

public class Example {
  public static void main(String[] args) {
    Runnable runnable = () -> System.out.println("Hello, World!");
    runnable.run();
  }
}

 

3. 메서드 레퍼런스 메서드 레퍼런스(method reference)는 람다 표현식을 더욱 간결하게 만들어주는 기능입니다. 메서드 레퍼런스는 :: 기호를 사용하여 표현하며, 메서드의 이름과 파라미터를 사용합니다.

 

4. 람다 표현식의 장점 자바 8에서 람다 표현식이 도입되면서 코드의 간결성과 가독성이 높아졌습니다. 람다 표현식을 사용하면 복잡한 코드를 간단하게 작성할 수 있으며, 코드의 중복을 줄이고 가독성을 높일 수 있습니다.

또한 람다 표현식은 함수형 프로그래밍을 지원하기 때문에 스트림(stream) API와 같은 다른 기능들과 함께 사용할 때 매우 유용합니다.

 

5. 람다 표현식의 단점 람다 표현식은 자바 8에서 도입된 기능으로, 이전 버전의 자바에서는 사용할 수 없습니다. 따라서 이전 버전과 호환성을 유지해야 하는 경우에는 람다 표현식 대신 익명 클래스를 사용해야 합니다.

 

또한 람다 표현식이 복잡한 로직을 다루는 경우에는 가독성이 떨어질 수 있습니다. 이러한 경우에는 람다 표현식보다는 일반적인 메서드를 사용하는 것이 더욱 적합할 수 있습니다.

 

스트림 API와 같은 다른 기능들과 함께 사용할 때 매우 유용합니다.

하지만 람다 표현식이 복잡한 로직을 다루는 경우에는 가독성이 떨어질 수 있으므로, 적절한 상황에서 사용해야 합니다.

또한 람다 표현식이 도입되면서 함수형 프로그래밍의 개념이 자바에 접목되었는데, 함수형 프로그래밍은 상태를 변경하지 않고 입력값만을 가지고 출력값을 생성하는 방식으로 코드를 작성하는 것을 말합니다. 이러한 방식으로 코드를 작성하면 예측 가능한 동작을 보장할 수 있으며, 코드의 안정성과 유지보수성을 높일 수 있습니다.

따라서 람다 표현식을 사용하면 자바 코드를 더욱 간결하고 유연하게 작성할 수 있으며, 함수형 프로그래밍의 장점을 누릴 수 있습니다. 하지만 적절한 상황에서 사용하고, 복잡한 로직은 일반적인 메서드를 사용하는 것이 더욱 바람직합니다.

+ Recent posts