Process the same input file concurrently Let's say we have a text file that contains 2 different types of lines. For the sake of example, one group starts with "i:" (for Integer) and the other group starts with "s:" (for String), something like the following file: s:New york s:Apple i:387548 s:Amsterdam i:4556 i:39874 s:Orange i:56787 s:Banana i:4657567 s:Turkey i:45679456 s:Iran i:4356456 i:23423 i:456 s:Ukraine i:453645 i:5456 We want to process these input lines separately but concurrently. And the process can be anything, for this example, we just print them to the console. But what matters is that we open the file only for READ so 2 different processes (or routines) can read the file at the same time. The Cats Effect answer to open files (or in general any resources) in a safe and efficient way, is Resource class. So we need a function to take the path to the file and give us a Resource of some type that allows us to read the file line by line. One o...
In this blog, I am trying to put practical examples for solving real-world small programming problems using Scala 3 (or sometimes 2). Most of the examples will leverage the 2 awesome Scala libraries, cats and cats-effects. There will be simple vanilla Scala examples as well that will not use any libraries as well as some advanced examples that might use other libraries such as http4s, doobie, and/or some scala frameworks such as Akka, or Play framework.

Comments
Post a Comment