playframework - 如何等待超时的承诺？

Question

我认为，以下内容将永远等待。如何指定超时？

await(new Job<Long>() {
    @Override
    public Long doJobWithResult() throws Exception {
        ...
    }
}.now());

Answer 1

实现一个杀死线程的超时实际上是一件非常困难的事情，因为你需要使用 Thread.stop() 或其他可怕的东西，当它死亡时可能无法清理。更好的方法是让超时在您的长期工作中设置一个标志，使其停止处理并更快地返回。或者，您让长时间的工作继续，并在超时时呈现响应。

这是一个可以满足您要求的测试用例：

https://github.com/playframework/play/blob/1.3.x/samples-and-tests/just-test-cases/app/controllers/WithContinuations.java#L73

public static void waitWithTimeout() {
        Promise<String> task1 = new jobs.DoSomething(100).now();
        Promise<String> task2 = new jobs.DoSomething(2000).now();
        Either<List<String>,Timeout> r = await(Promise.waitEither(Promise.waitAll(task1, task2), Timeout(300)));

        for(Timeout t : r._2) {

            StringBuilder result = new StringBuilder();

            if(task1.isDone()) {
                result.append(" + Task1 -> " + task1.getOrNull());
            }

            if(task2.isDone()) {
                result.append(" + Task2 -> " + task2.getOrNull());
            }

            renderText("Timeout! Partial result is " + result);
        }

        renderText("Fail!");
    }

Answer 2

指定动作之前的时间。所以对于 30 秒的超时：

await("30s", new Job<Long>() {
    @Override
    public Long doJobWithResult() throws Exception {
        ...
    }
}.now());