[Rust] Tokio 살펴보기

#Rust

tokio는 Rust 기반으로 작성된 비동기 런타임 라이브러리다.

쉽게말해 Go의 고루틴을 러스트로 포팅했다고 봐도 된다.
멀티스레딩과 병행성을 아주 효율적이고 편리하게 다룰 수 있도록 도와준다.

시스템급 언어들에는 이만한 라이브러리가 딱히 없어서, 여러 고성능 시스템의 코어에 많이 들어가는 중이다.
예를 들어, 그 유명한 AWS의 내부시스템에도 tokio와 러스트가 알차게 박혀있고, 지금도 들어가고 있다.

async-std라는 대체재도 있는데, 이건 성능에서 이점이 있는건 아니고 성능찾으려면 그냥 tokio 쓰면 된다.

일단 종속성에 먼저 tokio를 추가해보자.
이건 feature 수준을 세밀하게 조절할 필요가 있어서, cargo add보단 손으로 쳐주는게 좋다.

그럼 다음과 같이 Hello World 코드를 작성할 수 있겠다.
tokio::main과 async를 달아서 루트 영역에서도 비동기 핸들링을 해줄수 있게 하고, 예외처리가 편하도록 Result를 반환타입으로 했다.

그럼 잘 실행이 될 것이다.

스레드 올리기

tokio는 비동기 런타임이라고 했다.
그래서 비동기작업을 효율적으로 유지하기 위해, 네이티브 스레드보다는 런타임 단위의 경량 스레드를 주로 사용한다.

경량스레드 호출은 task 모듈의 spawn 함수로 처리할 수 있다. 그리고 async 블럭으로 수행할 로직을 전달받는다.

그리고 async/await 문법으로 잘 핸들링하면 된다.

외형은 일반 스레드와 다를것이 별로 없다.

여러 스레드를 한번에 await하고싶다면 join 매크로 등을 사용하면 된다.

tokio는 그냥 스레드 쏘는것만 주는게 아니라 동기화 도구들도 제공한다.

그 간편한 도구들 중 하나가 바로 채널이다.

다대다채널인 broadcast,
다중생산자에 단일소비자인 mpsc,
단일채널인 oneshot,
단일생산자에 다중소비자인 watch가 제공된다.

이런거는 별도 포스트에서 자세히 다루고, oneshot의 예시만 대강 보겠다.

이건 말그대로 스레드간에 한번 던지고 한번 받을 수 있는 단순한 채널이다.

그리고 파일 쓰기, 네트워킹 등의 기본적인 입출력기능도 그냥 제공한다.
io가 많을 경우에는 이런것들로만 써서 핸들링하는게 효율적이겠다.

그렇다.