java單線程怎么實(shí)現(xiàn)異步

138次閱讀

共計(jì) 1306 個(gè)字符，預(yù)計(jì)需要花費(fèi) 4 分鐘才能閱讀完成。

在 Java 中，單線程實(shí)現(xiàn)異步可以使用以下幾種方式：

使用線程池：創(chuàng)建一個(gè)線程池，通過提交任務(wù)到線程池中執(zhí)行，任務(wù)可以是實(shí)現(xiàn)了 Callable 或 Runnable 接口的對象，線程池會(huì)為每個(gè)任務(wù)分配一個(gè)線程去執(zhí)行，從而實(shí)現(xiàn)異步執(zhí)行的效果。

ExecutorService executorService = Executors.newFixedThreadPool(1);
Future<Integer> future = executorService.submit(new Callable<Integer>() {@Override
    public Integer call() throws Exception {// 異步執(zhí)行的代碼
        return 1;
    }
});

// 可以繼續(xù)執(zhí)行其他的代碼

try {Integer result = future.get(); // 獲取異步執(zhí)行的結(jié)果
    System.out.println(result);
} catch (InterruptedException e) {e.printStackTrace();
} catch (ExecutionException e) {e.printStackTrace();
}

executorService.shutdown(); // 關(guān)閉線程池

使用定時(shí)任務(wù)：使用 Timer 類或 ScheduledThreadPoolExecutor 類來執(zhí)行定時(shí)任務(wù)，通過指定延遲時(shí)間或者固定的時(shí)間間隔來執(zhí)行任務(wù)，從而實(shí)現(xiàn)異步執(zhí)行的效果。

Timer timer = new Timer();
timer.schedule(new TimerTask() {@Override
    public void run() {// 異步執(zhí)行的代碼
    }
}, delay);

// 可以繼續(xù)執(zhí)行其他的代碼

timer.cancel(); // 取消定時(shí)任務(wù)

使用回調(diào)函數(shù)：將異步執(zhí)行的結(jié)果通過回調(diào)函數(shù)的方式返回給調(diào)用方，從而實(shí)現(xiàn)異步的效果。

public interface Callback {void onSuccess(int result);
    void onFailure(Exception e);
}

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

// 調(diào)用異步方法
AsynchronousTask.execute(new Callback() {@Override
    public void onSuccess(int result) {System.out.println(result);
    }

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

// 可以繼續(xù)執(zhí)行其他的代碼