並行処理

こんにちは。スタディサプリの小中高プロダクト基盤開発グループでProduct Platform Engineer兼テックリードをやっている@tooooooooomyです。 今回は、WebアプリケーションにGoの並行処理機構を導入してSLOを改善し、WebAPIを100倍速くした話をしたいと思います。 前提条件 システムを0から作らない場合、アーキテクチャの改善の際には前提条件が付きものです。そこでまずは今回のシステムの前提条件をお話します。 対象となるシステムと、アーキテクチャ 今回対象とするシステムは、ここでは security-tracker と呼び、Webアプリケーション本体はGoで書か…

こんにちは！バックエンドエンジニアのjunyaUと申します。 実は9月入社で入社してから1ヶ月も経っていない（執筆当時）のですが、テックブログを書かせていただけるのは本当にありがたい環境だな〜とヒシヒシと感じております。 最近、プライベートではもっぱら自作OSの開発をしており、時間があっという間に溶けてしまいご飯をちゃんと食べれていないのが悩みです。 今回は並行処理と並列処理の違いをコンテキストの観点から考えて、両者がどのように違うのかを考察していこうと思います〜！ はじめに なぜ記事を書こうと思ったのか 数年前、私が学生だった頃に初めてGoを触り、そこで「並行処理」という言葉を初めて耳にしま…

はじめに せつ菜ちゃん & あげはさん、お誕生日おめでとうございます8️⃣8️⃣ nikkieです。 そんなよき日に非常に知的好奇心を刺激される"神"勉強会に参加してきました。 「並列処理をGo/Rust/Kotlin/Python/JSで解説！思想の違いを体感しよう」 目次 はじめに 目次 勉強会の概要 ベースとなる技術書典本 アーカイブ & 資料（みんなぜひ見て！） 感想：一覧できてすっごく面白かった！ Goルーチンで並列処理を実装しよう ちょっとしたデータ分析の並列化・Python Rustにおける並行処理 JavaScript の ⾮同期処理 Promise、 async/await …

はじめに 未来で待ってる。 nikkieです1。 ここ最近イベントループを使った並行処理（asyncio）を素振りしました。 これはI/Oバウンドな処理に有効です。 I/Oバウンドな処理にはマルチスレッドも有効と聞くので、少しだけ素振りしました。 目次 はじめに 目次 concurrent.futuresによるマルチスレッド 例で見るThreadPoolExecutor 『Python実践入門』を参考にした例 公式ドキュメント 終わりに concurrent.futuresによるマルチスレッド I/Oバウンドな処理の一例は、通信処理（具体的には、Web APIの大量呼び出し2）。 マルチスレッ…

こんにちは。たろすです。今回は並行処理におけるFork/Joinフレームワークについて説明します。 Fork/Joinフレームワークとは おわりに おすすめの学習本 Fork/Joinフレームワークとは Forkは分割、Joinは結合を意味しています。つまり、Fork/Joinフレームワークはタスクを分割して実行し、結果を結合するフレームワークです。以下のように使用します。 public class Task extends RecursiveTask<String> { @Override protected String compute() { return "Task ended"; }…

こんにちは。たろすです。今回は並行処理におけるCallableインタフェースについて説明します。 Callableインタフェースとは おわりに おすすめの学習本 Callableインタフェースとは マルチスレッドプログラミングで使われるRunnableインタフェースですが、Runnableインタフェースで定義されているrunメソッドは戻り値を返したり、例外をスローしたりできません。戻り値を返したり、例外をスローしたりしたいときに使用するのがCallableインタフェースです。Callableインタフェースで定義されているcallメソッドはそれらが可能です。 public class Main …

こんにちは。たろすです。今回は並行処理におけるExecutorインタフェースについて説明します。 Executorインタフェースとは おわりに おすすめの学習本 Executorインタフェースとは Exexutorインタフェースはタスク送信をタスクの実行方式から分離する方法を提供する、Threadクラスに代わるインタフェースです。以下のように使用します。 public class Main { public static void main(String[] aargs) { Runnable task = new Runnable() { public void run() { System…