并发 - 如何在J中异步调用方法

我最近一直在看Go的goroutines,并认为在Java中有类似的东西会很好。 据我所知,并行化方法调用的常用方法是执行以下操作:

final String x = "somethingelse";
new Thread(new Runnable() {
           public void run() {
                x.matches("something");             
    }
}).start();

那不是很优雅。 有没有更好的方法呢? 我在项目中需要这样的解决方案,所以我决定围绕异步方法调用实现自己的包装类。

我在J-Go发布了我的包装类。 但我不知道这是不是一个好的解决方案。 用法很简单:

SampleClass obj = ...
FutureResult<Integer> res = ...
Go go = new Go(obj);
go.callLater(res, "intReturningMethod", 10);         //10 is a Integer method parameter
//... Do something else
//...
System.out.println("Result: "+res.get());           //Blocks until intReturningMethod returns

或者更简洁:

Go.with(obj).callLater("myRandomMethod");
//... Go away
if (Go.lastResult().isReady())                //Blocks until myRandomMethod has ended
    System.out.println("Method is finished!");

在内部我使用实现Runnable的类并执行一些Reflection工作来获取正确的方法对象并调用它。

我想对我的小型库以及在Java中进行这样的异步方法调用的主题有所了解。 安全吗? 有没有更简单的方法?

11个解决方案
125 votes

我刚刚发现有一种更清洁的方法可以做到

new Thread(new Runnable() {
    public void run() {
        //Do whatever
    }
}).start();

(至少在Java 8中),您可以使用lambda表达式将其缩短为:

new Thread(() -> {
    //Do whatever
}).start();

就像在JS中创建一个函数一样简单!

AegisHexad answered 2019-08-13T20:12:28Z
31 votes

您可能还希望考虑课程FutureTask

如果您使用的是Java 5或更高版本,则FutureTask是&#34;可取消异步计算的交钥匙实现。&#34;

FutureTask包中提供了更丰富的异步执行调度行为(例如,ScheduledExecutorService),但FutureTask可能具有您需要的所有功能。

我甚至会说,自从FutureTask可用以来,不再使用您提供的第一个代码模式作为示例。 (假设您使用的是Java 5或更高版本。)

shadit answered 2019-08-13T20:13:14Z
21 votes

我不喜欢使用Reflection的想法。
不仅在某些重构中丢失它是危险的,但它也可以被FutureTask拒绝。

FutureTask是一个很好的选项,作为java.util.concurrent包中的其他选项。
我最喜欢的简单任务:

    Executors.newSingleThreadExecutor().submit(task);

比创建一个Thread稍微短一点(task是Callable或Runnable)

Carlos Heuberger answered 2019-08-13T20:14:07Z
17 votes

Java 8在java.util.concurrent.CompletableFuture包中引入了CompletableFuture,可用于进行异步调用:

CompletableFuture.runAsync(() -> {
    // method call or code to be asynch.
});
Rahul Chauhan answered 2019-08-13T20:14:32Z
9 votes

您可以使用来自jcabi-aspects和AspectJ的save()注释:

public class Foo {
  @Async
  public void save() {
    // to be executed in the background
  }
}

当您致电save()时,新线程将启动并执行其正文。 你的主线程继续而不等待save()的结果。

yegor256 answered 2019-08-13T20:15:05Z
9 votes

您可以使用CompletableFuture的Java8语法,这样您就可以根据调用异步函数的结果执行其他异步计算。

例如:

 CompletableFuture.supplyAsync(this::findSomeData)
                     .thenApply(this:: intReturningMethod)
                     .thenAccept(this::notify);

可以在本文中找到更多详细信息

Tal Avissar answered 2019-08-13T20:15:39Z
6 votes

您可以使用Future-AsyncResult。

@Async
public Future<Page> findPage(String page) throws InterruptedException {
    System.out.println("Looking up " + page);
    Page results = restTemplate.getForObject("http://graph.facebook.com/" + page, Page.class);
    Thread.sleep(1000L);
    return new AsyncResult<Page>(results);
}

参考:[https://spring.io/guides/gs/async-method/]

user3177227 answered 2019-08-13T20:16:11Z
2 votes

这并不是真正相关,但如果我要异步调用一个方法,例如 matches(),我会用:

private final static ExecutorService service = Executors.newFixedThreadPool(10);
public static Future<Boolean> matches(final String x, final String y) {
    return service.submit(new Callable<Boolean>() {

        @Override
        public Boolean call() throws Exception {
            return x.matches(y);
        }

    });
}

然后调用我将使用的异步方法:

String x = "somethingelse";
try {
    System.out.println("Matches: "+matches(x, "something").get());
} catch (InterruptedException e) {
    e.printStackTrace();
} catch (ExecutionException e) {
    e.printStackTrace();
}

我测试了这个并且它有效。 只是认为如果他们只是来参加&#34;异步方法&#34;它可能会有所帮助。

FlameBlazer answered 2019-08-13T20:16:50Z
2 votes

它可能不是一个真正的解决方案,但现在 - 在Java 8中 - 您可以使用lambda表达式使这些代码看起来至少更好一些。

final String x = "somethingelse";
new Thread(() -> {
        x.matches("something");             
    }
).start();

你甚至可以在一行中做到这一点,仍然具有可读性。

new Thread(() -> x.matches("something")).start();
kcpr answered 2019-08-13T20:17:23Z
2 votes

你可以使用Cactoos的get()

boolean matches = new AsyncFunc(
  x -> x.matches("something")
).apply("The text").get();

它将在后台执行,结果将在get()中以Future的形式提供。

yegor256 answered 2019-08-13T20:17:56Z
0 votes

Java还提供了一种调用异步方法的好方法。 在java.util.concurrent中,我们有ExecutorService,它有助于做同样的事情。 像这样初始化你的对象 -

 private ExecutorService asyncExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());

然后调用函数 -

asyncExecutor.execute(() -> {

                        TimeUnit.SECONDS.sleep(3L);}
Anand answered 2019-08-13T20:18:29Z
translate from https://stackoverflow.com:/questions/1842734/how-to-asynchronously-call-a-method-in-java