Javaのシングルスレッドで非同期を実現する方法

2年 ago
海斗, 葵
1 minute

Javaにおいて、シングルスレッドで非同期を実現する方法には以下のようなものがあります。

  1. スレッドプールを活用する：スレッドプールを作成することで、コールバックや実行可能なインターフェースオブジェクトをプールに送信することで、各タスクにスレッドが割り当てられ、非同期実行が実現します。
ExecutorService executorService = Executors.newFixedThreadPool(1);
Future<Integer> future = executorService.submit(new Callable<Integer>() {
    @Override
    public Integer call() throws Exception {
        // 异步执行的代码
        return 1;
    }
});

// 可以继续执行其他的代码

try {
    Integer result = future.get(); // 获取异步执行的结果
    System.out.println(result);
} catch (InterruptedException e) {
    e.printStackTrace();
} catch (ExecutionException e) {
    e.printStackTrace();
}

executorService.shutdown(); // 关闭线程池
  1. タイマー
  2. ネイティブではスケジュールされたスレッドプールがあります
Timer timer = new Timer();
timer.schedule(new TimerTask() {
    @Override
    public void run() {
        // 异步执行的代码
    }
}, delay);

// 可以继续执行其他的代码

timer.cancel(); // 取消定时任务
  1. コールバック関数を使用：非同期処理の結果をコールバック関数という形で呼び出し側に返すことで非同期処理を実現する。
public interface Callback {
    void onSuccess(int result);
    void onFailure(Exception e);
}

public class AsynchronousTask {
    public static void execute(Callback callback) {
        new Thread(() -> {
            try {
                // 异步执行的代码
                int result = 1;
                callback.onSuccess(result);
            } catch (Exception e) {
                callback.onFailure(e);
            }
        }).start();
    }
}

// 调用异步方法
AsynchronousTask.execute(new Callback() {
    @Override
    public void onSuccess(int result) {
        System.out.println(result);
    }

    @Override
    public void onFailure(Exception e) {
        e.printStackTrace();
    }
});

// 可以继续执行其他的代码

3つの一般的なシングルスレッドでの非同期実装の方法を上に示したので、具体的な用途やシーンに応じて適切な方法を選択して使用してください。

bannerAds