212

I am a normal C# developer but occasionally I develop application in Java. I'm wondering if there is any Java equivalent of C# async/await? In simple words what is the java equivalent of:

async Task<int> AccessTheWebAsync()
{ 
    HttpClient client = new HttpClient();
    var urlContents = await client.GetStringAsync("http://msdn.microsoft.com");
    return urlContents.Length;
}
17
  • 10
    Why this would be nice: Callbacks as our Generations’ Go To Statement by Miguel de Icaza.
    – andrewdotn
    Nov 12, 2013 at 4:00
  • 6
    There is no equivalent. And it hurts. One more missing feature you need complicated workarounds and libraries for, without ever reaching the same effect as these two, simple words.
    – spyro
    Dec 12, 2019 at 17:35
  • 1
    @PhilipCouling I don't believe there is any need to do any change in the bytecode to support async await. It's just syntactic sugar around Futures, nothing more. As a matter of fact, in JavaScript, you can transpile your async/await code in Future equivalent for backward compatibility. It's just about building a state machine, which you can do by generating bytecode. No need for changes in the JVM.
    – pieroxy
    Aug 27, 2021 at 13:52
  • 2
    @pieroxy no async is not multithreading and python had multithreading long before async. Multithreading uses operating system threads and the OS time slices between them. Async uses a single OS thread and the application takes responsibility to switch tasks when a task reaches a logical point where it must stop ( eg network read). The whole point of async is that it it reuses the same thread to perform other tasks while a task is blocking. The lack of threading is purely a JavaScript thing. Aug 30, 2021 at 9:00
  • 2
    @pieroxy still no. Even in c# the core concept remains the same and is not syntactic sugar (as described by jon skeet). Sure multiple threads may execute tasks from the same pool but that doesn't mean async is a threading model. Async is hard to understand and many people don't. In all languages that support async; await can suspend the entire call stack of the task and executes something different on the same thread. In java you just can't suspend the stack and restore it later. Aug 30, 2021 at 10:33

15 Answers 15

181

No, there isn't any equivalent of async/await in Java - or even in C# before v5.

It's a fairly complex language feature to build a state machine behind the scenes.

There's relatively little language support for asynchrony/concurrency in Java, but the java.util.concurrent package contains a lot of useful classes around this. (Not quite equivalent to the Task Parallel Library, but the closest approximation to it.)

15
  • 19
    @user960567: No, my point is that it's a language feature - it can't be put solely in libraries. I don't believe there's any equivalent scheduled for Java 8 at least.
    – Jon Skeet
    May 14, 2013 at 9:23
  • 12
    @user960567: You need to distinguish between the version of C# you're using and the version of .NET you're using. async/await is a language feature - it was introduced in C# 5. Yes, you can use Microsoft.Bcl.Async to use async/await targeting .NET 4, but you've still got to use a C# 5 compiler.
    – Jon Skeet
    May 14, 2013 at 9:31
  • 6
    @rozar: No, not really. There are already multiple options for asynchrony - but RxJava doesn't change the language in the way that C# did. I have nothing against Rx, but it's not the same thing as async in C# 5.
    – Jon Skeet
    Mar 26, 2014 at 6:46
  • 11
    @DtechNet: Well there's a lot of JVM machinery which is asynchronous, yes... that's very different from there being actual language features supporting asynchrony though. (There was a lot of asynchrony in .NET before async/await, too... but async/await makes it far easier to take advantage of that.)
    – Jon Skeet
    Oct 21, 2015 at 5:45
  • 5
    @Aarkon: I would argue that unless there's explicit language support, the answer is still correct. It's not just a matter of libraries that make scheduling simpler - the whole way the C# compiler builds a state machine is important here.
    – Jon Skeet
    Jun 11, 2019 at 11:09
52

The await uses a continuation to execute additional code when the asynchronous operation completes (client.GetStringAsync(...)).

So, as the most close approximation I would use a CompletableFuture<T> (the Java 8 equivalent to .net Task<TResult>) based solution to process the Http request asynchronously.

UPDATED on 25-05-2016 to AsyncHttpClient v.2 released on Abril 13th of 2016:

So the Java 8 equivalent to the OP example of AccessTheWebAsync() is the following:

CompletableFuture<Integer> AccessTheWebAsync()
{
    AsyncHttpClient asyncHttpClient = new DefaultAsyncHttpClient();
    return asyncHttpClient
       .prepareGet("http://msdn.microsoft.com")
       .execute()
       .toCompletableFuture()
       .thenApply(Response::getResponseBody)
       .thenApply(String::length);
}

This usage was taken from the answer to How do I get a CompletableFuture from an Async Http Client request? and which is according to the new API provided in version 2 of AsyncHttpClient released on Abril 13th of 2016, that has already intrinsic support for CompletableFuture<T>.

Original answer using version 1 of AsyncHttpClient:

To that end we have two possible approaches:

  • the first one uses non-blocking IO and I call it AccessTheWebAsyncNio. Yet, because the AsyncCompletionHandler is an abstract class (instead of a functional interface) we cannot pass a lambda as argument. So it incurs in inevitable verbosity due to the syntax of anonymous classes. However, this solution is the most close to the execution flow of the given C# example.

  • the second one is slightly less verbose however it will submit a new Task that ultimately will block a thread on f.get() until the response is complete.

First approach, more verbose but non-blocking:

static CompletableFuture<Integer> AccessTheWebAsyncNio(){
    final AsyncHttpClient asyncHttpClient = new AsyncHttpClient();
    final CompletableFuture<Integer> promise = new CompletableFuture<>();
    asyncHttpClient
        .prepareGet("https://msdn.microsoft.com")
        .execute(new AsyncCompletionHandler<Response>(){
            @Override
            public Response onCompleted(Response resp) throws Exception {
                promise.complete(resp.getResponseBody().length());
                return resp;
            }
        });
    return promise;
}

Second approach less verbose but blocking a thread:

static CompletableFuture<Integer> AccessTheWebAsync(){
    try(AsyncHttpClient asyncHttpClient = new AsyncHttpClient()){
        Future<Response> f = asyncHttpClient
            .prepareGet("https://msdn.microsoft.com")
            .execute();
        return CompletableFuture.supplyAsync(
            () -> return f.join().getResponseBody().length());
    }
}
4
  • 4
    Actually, that's the equivalent of the happy flow. It doesn't cover handling exceptions, finally and others. Including them will make the code much more complex and more prone to errors.
    – haimb
    Jan 16, 2019 at 6:20
  • 6
    This isn't a continuation. This example misses the real purpose of async/await, which is to release the current thread to execute other things, and then to continue execution of this method on the current thread after a response arrives. (This is either necessary for the UI thread to be responsive, or to reduce memory usage.) What this example does is a plain blocking thread synchronization, plus some callbacks. Nov 12, 2019 at 21:52
  • 1
    @AleksandrDubinsky I agree with you when you point that the callback may not run on the caller thread. You are right. I disagree about blocking a thread. My updated answer of UPDATED on 25-05-2016 is non-blocking. Nov 13, 2019 at 13:37
  • 3
    .... and this sample is exactly the reason why C# is so much simpler to write and read when doing asynchronous stuff. It's just a pain in Java.
    – spyro
    Dec 12, 2019 at 17:37
15

There is no equivalent of C# async/await in Java at the language level. A concept known as Fibers aka cooperative threads aka lightweight threads could be an interesting alternative. You can find Java libraries providing support for fibers.

Java libraries implementing Fibers

You can read this article (from Quasar) for a nice introduction to fibers. It covers what threads are, how fibers can be implemented on the JVM and has some Quasar specific code.

7
  • 13
    async/await in C# is not a Fiber. It just compiler magic that use continuation on Promise (the Task class) by registering a callback. Jun 27, 2016 at 5:59
  • 1
    @UltimaWeapon So what do you consider to be fibers? Dec 14, 2018 at 16:09
  • @AleksandrDubinsky One of the example is goroutine. Dec 15, 2018 at 10:19
  • 1
    @UltimaWeapon I was looking for an explanation. Dec 16, 2018 at 8:36
  • @AleksandrDubinsky I'm lazy to explain it. If you really want to know you may search the article about under the hood of goroutine. Dec 16, 2018 at 15:05
14

async and await are syntactic sugars. The essence of async and await is state machine. The compiler will transform your async/await code into a state machine.

At the same time, in order for async/await to be really practicable in real projects, we need to have lots of Async I/O library functions already in place. For C#, most original synchronized I/O functions has an alternative Async version. The reason we need these Async functions is because in most cases, your own async/await code will boil down to some library Async method.

The Async version library functions in C# is kind of like the AsynchronousChannel concept in Java. For example, we have AsynchronousFileChannel.read which can either return a Future or execute a callback after the read operation is done. But it’s not exactly the same. All C# Async functions return Tasks (similar to Future but more powerful than Future).

So let’s say Java do support async/await, and we write some code like this:

public static async Future<Byte> readFirstByteAsync(String filePath) {
    Path path = Paths.get(filePath);
    AsynchronousFileChannel channel = AsynchronousFileChannel.open(path);

    ByteBuffer buffer = ByteBuffer.allocate(100_000);
    await channel.read(buffer, 0, buffer, this);
    return buffer.get(0);
}

Then I would imagine the compiler will transform the original async/await code into something like this:

public static Future<Byte> readFirstByteAsync(String filePath) {

    CompletableFuture<Byte> result = new CompletableFuture<Byte>();

    AsyncHandler ah = new AsyncHandler(result, filePath);

    ah.completed(null, null);

    return result;
}

And here is the implementation for AsyncHandler:

class AsyncHandler implements CompletionHandler<Integer, ByteBuffer>
{
    CompletableFuture<Byte> future;
    int state;
    String filePath;

    public AsyncHandler(CompletableFuture<Byte> future, String filePath)
    {
        this.future = future;
        this.state = 0;
        this.filePath = filePath;
    }

    @Override
    public void completed(Integer arg0, ByteBuffer arg1) {
        try {
            if (state == 0) {
                state = 1;
                Path path = Paths.get(filePath);
                AsynchronousFileChannel channel = AsynchronousFileChannel.open(path);

                ByteBuffer buffer = ByteBuffer.allocate(100_000);
                channel.read(buffer, 0, buffer, this);
                return;
            } else {
                Byte ret = arg1.get(0);
                future.complete(ret);
            }

        } catch (Exception e) {
            future.completeExceptionally(e);
        }
    }

    @Override
    public void failed(Throwable arg0, ByteBuffer arg1) {
        future.completeExceptionally(arg0);
    }
}
16
  • 26
    Syntatic sugar? Do you have any idea about how to wrap exceptions around async code, and loops around async code?
    – Akash Kava
    Jul 29, 2016 at 11:31
  • 69
    Classes, too, are syntactic sugar. The compiler creates all the trees and lists of function pointers you would normally write by hand for you fully automatically. These functions / methods are syntactic sugar, too. They auto-generate all the gotos you would normally, being a real programmer, write by hand. Assembler is syntactic sugar, too. Real programmers manually write machine code and manually port it to all target architectures.
    – yeoman
    Oct 11, 2016 at 12:31
  • 51
    Thinking abou itt, computers themselves are just syntactic sugar for l4m3 n00bz. Real programmers solder them tiny integrated circuits to a wooden board and connect them with gold wire because circuit boards are syntactic sugar, just like mass production, shoes, or food.
    – yeoman
    Oct 11, 2016 at 12:35
  • 3
    Right, syntactic sugar that reduces the amount of code to maintain, understand, and step through by a couple orders of magnitude is so hipster. Sep 19, 2021 at 14:17
  • Something can only be called syntactic sugar when it's possible to write equivalent code that doesn't use it. That's not the case here, the things going on behind the scenes in async/await have no way to be expressed using java syntax.
    – entonio
    Nov 28, 2022 at 0:50
9

As it was mentioned, there is no direct equivalent, but very close approximation could be created with Java bytecode modifications (for both async/await-like instructions and underlying continuations implementation).

I'm working right now on a project that implements async/await on top of JavaFlow continuation library, please check https://github.com/vsilaev/java-async-await

No Maven mojo is created yet, but you may run examples with supplied Java agent. Here is how async/await code looks like:

public class AsyncAwaitNioFileChannelDemo {

public static void main(final String[] argv) throws Exception {

    ...
    final AsyncAwaitNioFileChannelDemo demo = new AsyncAwaitNioFileChannelDemo();
    final CompletionStage<String> result = demo.processFile("./.project");
    System.out.println("Returned to caller " + LocalTime.now());
    ...
}


public @async CompletionStage<String> processFile(final String fileName) throws IOException {
    final Path path = Paths.get(new File(fileName).toURI());
    try (
            final AsyncFileChannel file = new AsyncFileChannel(
                path, Collections.singleton(StandardOpenOption.READ), null
            );              
            final FileLock lock = await(file.lockAll(true))
        ) {

        System.out.println("In process, shared lock: " + lock);
        final ByteBuffer buffer = ByteBuffer.allocateDirect((int)file.size());

        await( file.read(buffer, 0L) );
        System.out.println("In process, bytes read: " + buffer);
        buffer.rewind();

        final String result = processBytes(buffer);

        return asyncResult(result);

    } catch (final IOException ex) {
        ex.printStackTrace(System.out);
        throw ex;
    }
}

@async is the annotation that flags a method as asynchronously executable, await() is a function that waits on CompletableFuture using continuations and a call to "return asyncResult(someValue)" is what finalizes associated CompletableFuture/Continuation

As with C#, control flow is preserved and exception handling may be done in regular manner (try/catch like in sequentially executed code)

7

Java itself has no equivalent features, but third-party libraries exist which offer similar functionality, e.g.Kilim.

1
  • 5
    I don't think this library has anything to do with what async/await does.
    – Natan
    Aug 29, 2014 at 13:05
7

Java doesn't have a direct equivalent to the C# language feature called async/await. However, starting from OpenJDK 21, Java introduced virtual threads, which provide a lightweight mechanism for concurrency. Unlike traditional threads, virtual threads significantly reduce overhead, allowing for the spawning of millions of threads without running into scalability issues.

Additionally, the virtual thread approach in Java addresses the "colored function problem" associated with async/await.

A similar concurrency mechanism is present in Golang, known as goroutines.

2
  • 2
    I'm looking forward to this. I'm learning Java, coming from Node.js and Go, and this is painful. Node.js has async/await (the colored function problem never bothered me much) and Go has goroutines so you just write blocking code in the millions of cheap goroutines you spawn. Java seems to have neither and needs me to use things like java.util.concurrent or RxJava to make my code non-blocking. If my understanding of Project Loom is correct, it'll make coding asynchronous things in Java as easy as Go. You'd just write blocking code without worrying about running out of "threads" able to execute.
    – Matt Welke
    May 29, 2021 at 18:14
  • 1
    @MattWelke Yes, that's correct understanding. Aug 11, 2021 at 15:10
6

First, understand what async/await is. It is a way for a single-threaded GUI application or an efficient server to run multiple "fibers" or "co-routines" or "lightweight threads" on a single thread. Of note is that it uses the cooperative form of multi-threading, as opposed to pre-emptive. It is meant to solve one of two, separate issues. The first is that the framework developer found it too hard to do concurrent programming (typical of GUI frameworks). The second is that OS threads have too much overhead, particularly memory usage (typical of server frameworks).

In case you don't have either problem, then just use regular OS multi-threading. This is often easier and faster than asynchronous programming. To launch threads, consider using ExecutorService.submit and Future.get or the upcoming StructuredTaskScope. Inside of those threads, use ordinary synchronous, blocking calls.

In case your problem is scalability and OS thread overhead, then know that Java 21 offers "virtual" threads. These are a lot like OS threads, but use much less memory. Go has a similar feature called goroutines.

For older versions of Java, you'll need to look to your framework, which has likely implemented some sort of "asynchronous" optimization. Many frameworks have done this, including Servlet 3.0. These don't have the elegance of language features, though. They work through ordinary callbacks.

In case your problem is concurrency, then you likewise need to look at your framework. For example, JavaFX offers javafx.concurrent.Task.

1
  • 3
    Here is an article quote restarting this answer's first paragraph //start quote For client applications, such as Windows Store, Windows desktop and Windows Phone apps, the primary benefit of async is responsiveness. These types of apps use async chiefly to keep the UI responsive. For server applications, the primary benefit of async is scalability. msdn.microsoft.com/en-us/magazine/dn802603.aspx Dec 12, 2018 at 18:46
5

There is an "equivalent" of await developed by EA: https://github.com/electronicarts/ea-async. Refer to the Java example code:

import static com.ea.async.Async.await;
import static java.util.concurrent.CompletableFuture.completedFuture;

public class Store
{
    public CompletableFuture<Boolean> buyItem(String itemTypeId, int cost)
    {
        if(!await(bank.decrement(cost))) {
            return completedFuture(false);
        }
        await(inventory.giveItem(itemTypeId));
        return completedFuture(true);
    }
}
1
3

There isn't anything native to java that lets you do this like async/await keywords, but what you can do if you really want to is use a CountDownLatch. You could then imitate async/await by passing this around (at least in Java7). This is a common practice in Android unit testing where we have to make an async call (usually a runnable posted by a handler), and then await for the result (count down).

Using this however inside your application as opposed to your test is NOT what I am recommending. That would be extremely shoddy as CountDownLatch depends on you effectively counting down the right number of times and in the right places.

2

I make and released Java async/await library. https://github.com/stofu1234/kamaitachi

This library don't need compiler extension, and realize stackless IO processing in Java.

    async Task<int> AccessTheWebAsync(){ 
        HttpClient client= new HttpClient();
        var urlContents= await client.GetStringAsync("http://msdn.microsoft.com");
       return urlContents.Length;
    }

   ↓

    //LikeWebApplicationTester.java
    BlockingQueue<Integer> AccessTheWebAsync() {
       HttpClient client = new HttpClient();
       return awaiter.await(
            () -> client.GetStringAsync("http://msdn.microsoft.com"),
            urlContents -> {
                return urlContents.length();
            });
    }
    public void doget(){
        BlockingQueue<Integer> lengthQueue=AccessTheWebAsync();
        awaiter.awaitVoid(()->lengthQueue.take(),
            length->{
                System.out.println("Length:"+length);
            }
            );
    }
1
  • How would you handle String x = await f(); if(x == "Facebook") { LongAsyncFuncToRunFacebook();} else {LongAsyncFuncToRunSomethingElse();} AfterIfElseRunSomethingNewJustForFun();
    – pratikpc
    Jan 4, 2021 at 4:15
1

Java has unfortunately no equivalent of async/await. The closest you can get is probably with ListenableFuture from Guava and listener chaining, but it would be still very cumbersome to write for cases involving multiple asynchronous calls, as the nesting level would very quickly grow.

If you're ok with using a different language on top of JVM, fortunately there is async/await in Scala which is a direct C# async/await equivalent with an almost identical syntax and semantics: https://github.com/scala/async/

Note that although this functionality needed a pretty advanced compiler support in C#, in Scala it could be added as a library thanks to a very powerful macro system in Scala and therefore can be added even to older versions of Scala like 2.10. Additionally Scala is class-compatible with Java, so you can write the async code in Scala and then call it from Java.

There is also another similar project called Akka Dataflow http://doc.akka.io/docs/akka/2.3-M1/scala/dataflow.html which uses different wording but conceptually is very similar, however implemented using delimited continuations, not macros (so it works with even older Scala versions like 2.9).

0

If you're just after clean code which simulates the same effect as async/await in java and don't mind blocking the thread it is called on until it is finished, such as in a test, you could use something like this code:

interface Async {
    void run(Runnable handler);
}

static void await(Async async) throws InterruptedException {

    final CountDownLatch countDownLatch = new CountDownLatch(1);
    async.run(new Runnable() {

        @Override
        public void run() {
            countDownLatch.countDown();
        }
    });
    countDownLatch.await(YOUR_TIMEOUT_VALUE_IN_SECONDS, TimeUnit.SECONDS);
}

    await(new Async() {
        @Override
        public void run(final Runnable handler) {
            yourAsyncMethod(new CompletionHandler() {

                @Override
                public void completion() {
                    handler.run();
                }
            });
        }
    });
0

I have developed a library JAsync to do this. It is just released today. It makes the developer's asynchronous programming experience as close as possible to the usual synchronous programming, including code style and debugging. Here is the example.

@RestController
@RequestMapping("/employees")
public class MyRestController {
    @Inject
    private EmployeeRepository employeeRepository;
    @Inject
    private SalaryRepository salaryRepository;

    // The standard JAsync async method must be annotated with the Async annotation, and return a Promise object.
    @Async()
    private Promise<Double> _getEmployeeTotalSalaryByDepartment(String department) {
        double money = 0.0;
        // A Mono object can be transformed to the Promise object. So we get a Mono object first.
        Mono<List<Employee>> empsMono = employeeRepository.findEmployeeByDepartment(department);
        // Transformed the Mono object to the Promise object.
        Promise<List<Employee>> empsPromise = JAsync.from(empsMono);
        // Use await just like es and c# to get the value of the Promise without blocking the current thread.
        for (Employee employee : empsPromise.await()) {
            // The method findSalaryByEmployee also return a Mono object. We transform it to the Promise just like above. And then await to get the result.
            Salary salary = JAsync.from(salaryRepository.findSalaryByEmployee(employee.id)).await();
            money += salary.total;
        }
        // The async method must return a Promise object, so we use just method to wrap the result to a Promise.
        return JAsync.just(money);
    }

    // This is a normal webflux method.
    @GetMapping("/{department}/salary")
    public Mono<Double> getEmployeeTotalSalaryByDepartment(@PathVariable String department) { 
        // Use unwrap method to transform the Promise object back to the Mono object.
        return _getEmployeeTotalSalaryByDepartment(department).unwrap(Mono.class);
    }
}

And in debug mode, you can see all the variable just like the synchronous code.

enter image description here

The other great thing about this project is that it's one of the few projects of its kind that's still active right now. It's just been released, so it has a lot of potential

0

java.util.concurrent provides easy to use classes that do the same thing as async/await.

In the example below, onDeviceInfoReceived sets the class' deviceInfo object and is called sometime after the device info request because it takes some time to process, as happens in web or file I/O requests.

getDeviceInfoAsync waits for deviceInfo to be non-null (or 100ms) and returns the future, the same way an async task does. And you can get the DeviceInfo object from the future using the get method. You can even specify a timeout, as shown in getAnalyzerInfo.

public void onDeviceInfoReceived(DeviceInfo devInfo) {
    this.deviceInfo = devInfo;
}

public DeviceInfo getDeviceInfo() {
    Future<DeviceInfo> future = getDeviceInfoAsync();
    DeviceInfo info = null;
    try {
        info = future.get(100, TimeUnit.MILLISECONDS);
    } catch (Exception e) {

    }
    return info;
}

private Future<DeviceInfo> getDeviceInfoAsync() {
    ExecutorService executor = Executors.newSingleThreadExecutor();
    Callable<DeviceInfo> callable = () -> {
        long startTime = System.currentTimeMillis();
        while (deviceInfo == null) {
            if (System.currentTimeMillis() - startTime > 100) {
                return null;
            }
            Thread.sleep(10);
        }
        return deviceInfo;
    };
    Future<DeviceInfo> future = executor.submit(callable);
    executor.shutdown();
    return future;
}

The C# equivalent method would be:

public async Task<DeviceInfo> GetDeviceInfoAsync() 

and you cal call it using DeviceInfo info = await GetDeviceInfoAsync()

Not the answer you're looking for? Browse other questions tagged or ask your own question.