Asynchronous Programming in Grails 3
Grails has had support for asynchronous programming for some time now but it seems to have become more well-defined in Grails 3. It has Promises, Events, and even asynchronous processing in GORM. The article is focusing on some functionality in Event processing, most of the functionality coming from Reactor.
You can see my simple example on Github. It’s pretty straightforward on how it works — you enter a number into a form, and then check the server output for counting from 1 to that number. The numbers won’t be in order though — that is because a service is sending them to another service in an asynchronous manner.
LoopService is really what starts this off — it gets a number and starts the loop:
Note that it doesn’t call another service directly — instead it calls this magic
notify method that takes a string and the value. This is because services in Grails 3 have the
Event trait which give you an interface into Reactor. The string is the name of the event to fire and the second parameter is the Object to send to the consumer of the event. Notice that I said Object… I first used type
int to make this example and it took me awhile to figure out why I had a
NullPointerExeception. Simply moving it to
Integer made it start working.
The consumer of this event is the
Selector annotations come from Reactor.
Consumer simply signifies that this class consumes events and
Selector lets you give the name of the event that method consumes. Note that the
echo method consumes the
int.echo event we used above. I think the other important thing to note is that there is nothing else do to! There is nothing in the method itself that signifies that it’s running in an asynchronous matter. And you could use the same method in a synchronous scenario if need be by calling the method directly.
One thought on “Asynchronous Programming in Grails 3”
Very nice post Mike! I recently started using asynchronous programming, and I have a doubt. What is the best (or most viable) way to test those situations when one service emit an event, and one or more services ?