Java 8 Concurrency and Reactive Programming using RxJava

Java 8 Concurrency and Reactive Programming using RxJava 2 is a two-day, fast-paced coding course geared for experienced developers who have prior working knowledge of Java. Throughout the course students learn the best practices for writing non-blocking applications in Java 8 using both the Java Concurrency Framework and the RxJava 2 API. The course provides an in-depth view of the enhancements made to the Java Concurrency API in Java 8, allowing for the development of non-blocking asynchronous processes.

Retail Price: $1,895.00

Next Date: Request Date

Course Days: 2


Request a Date

Request Custom Course


Course Objectives

This “skills-centric” course is about 50% hands-on lab and 50% lecture, designed to train attendees in next-level Java development skills, coupling the most current, effective techniques with the soundest industry practices. Throughout the course students will be led through a series of progressively advanced topics, where each topic consists of lecture, group discussion, comprehensive hands-on lab exercises, and lab review.

Our engaging instructors and mentors are highly experienced practitioners who bring years of current "on-the-job" experience into every classroom. Working within in a hands-on learning environment, guided by our expert team, attendees will explore:

  • Explore Parallel programming in Java including coverage of multithreading and concurrency
  • The asynchronous, non-blocking concurrency API introduced in Java 8
  • Reactive Programming in Java using Project Reactor
  • Understand event publishers and Subscribers
  • Apply operators to Reactive events
  • Understand the concept of Backpressure
  • Properly handle exceptions in the reactive process

 

Course Prerequisites

This is an intermediate level Java SE (JSE) developer course, designed for experienced Java 8 developers. Attendees should have current hands-on experience in developing basic Java 8 applications.  This course is NOT for new developers or non-developers.


Course Agenda

 

Please note that this list of topics is based on our standard course offering, evolved from typical industry uses and trends. We’ll work with you to tune this course and level of coverage to target the skills you need most.

Session: Multithreading and Concurrency

  • Lesson: Introduction to Multithreading and Concurrency
  • Principles of Multithreading
  • The Thread class and Runnable interface
  • Explore thread synchronization
  • Introduce the Java Concurrency API

Lesson: Concurrent Java

  • Thread management using Executors
  • The common thread-pool
  • Submitting and controlling asynchronous tasks
  • Explore the locking API
  • Lab: Working with Concurrent Java

Lesson: Non-blocking asynchronous tasks

  • The CompletableFuture
  • Define non-blocking processes
  • Lab: CompletableFuture

Session: Introduction to RxJava2

Lesson: Introduction

  • Introduce ReactiveX and RxJava 2
  • The Observer and Iterator pattern and functional programming
  • Introduce the RxJava 2 Building blocks
  • Discuss hot and cold observables
  • Registering operators
  • Subscribing to an Observable
  • Lab: RxJava Introduction

Lesson: Testing Event Sources (Introduction)

  • Introduce the TestObserver and TestSubscriber
  • Testing Observable implementations
  • Introduce some commonly used assertions
  • Lab: Testing the Observable

Lesson: Operators

  • Introduce RxJava 2 Operators
  • Show the use of RxMarbles (marble diagrams)
  • Explain some commonly used operators
  • Callback operators
  • Lab: RxJava Operations

Lesson: Creating the event publisher

  • Implementing the event source
  • Introduce the different types of event publishers
  • Convenience methods for creation of publishers
  • Creating an event source using an Emitter
  • Pre-defined observables
  • The defer operator
  • ConnectableObservable
  • Lab: RxJava Observables

Session: Working with RxJava2

Lesson: Subjects

  • RxJava subjects
  • Enable multicasting using Subjects
  • Introduce most commonly used Subject implementations
  • Lab: RxJava Subjects

Lesson: RxJava Schedulers (Multithreading)

  • Thread usage of Observable, Operator and Observer
  • Using the subscribeOn method
  • Introduce the Scheduler implementations
  • Using the observeOn method

Lesson: Testing (multi-threaded) Event Sources

  • Testing Asynchronous code
  • Discuss strategies for testing event sources
  • Waiting for source to complete (await methods)
  • Use RxJava extension mechanism to Scheduler instances used during test
  • The JUnit 5 @ExtendsWith and @RegisterExtension annotations
  • Using the TestScheduler to advance time during test
  • Lab: Testing Asynchronous Event sources

Lesson: Backpressure

  • Strategies for dealing with Backpressure
  • Reactive Streams
  • Flowable and Processor
  • “reactive pull” backpressure
  • Lab: RxJava Backpressure

Lesson: Exception Handling

  • Handling errors in onError
  • Exception handling strategies
  • Using onErrorReturn or onErrorNext operators
  • Using the retry operators
  • The Global Error Handler
  • Lab: RxJava Exceptions


Sorry! It looks like we haven’t updated our dates for the class you selected yet. There’s a quick way to find out. Contact us at 502.265.3057 or email info@training4it.com


Request a Date