StackStalk
  • Home
  • Java
    • Java Collection
    • Spring Boot Collection
  • Python
    • Python Collection
  • C++
    • C++ Collection
    • Progamming Problems
    • Algorithms
    • Data Structures
    • Design Patterns
  • General
    • Tips and Tricks

Saturday, September 13, 2014

Java Exchanger

 September 13, 2014     Java     No comments   

Exchanger Introduction

Exchanger is a synchronization point in which threads can pair and exchange objects. Exchanger simplifies data exchange between two threads. Exchanger waits till two threads reach the synchronization point and then exchanges the data provided by the threads.

Java Exchanger Class

Java supports Exchanger synchronization object. Exchanger is a generic class and support the following key APIs.
  • Exchanger() - Constructor to create the exchanger.
  • public V exchange(V x) - Waits for the partner thread to arrive at the exchange point and then swaps the objects

Java Exchanger Example

In this example, we create in the main() program an Exchanger instance for strings. This Exchanger object is then used to exchange strings between the two threads.
package com.sourcetricks.exchanger;

import java.util.concurrent.Exchanger;

public class ExchangerDemo {

  private static class MyTask1 implements Runnable {

    Exchanger<String> exchanger;
    
    MyTask1(Exchanger<String> exchanger) {
      this.exchanger = exchanger;
    }
    
    @Override
    public void run() {
      String str = null;
      try {
        str = exchanger.exchange("Hello from MyTask1");
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println("Received in MyTask1 = " + str);
    }
    
  }
  
  private static class MyTask2 implements Runnable {

    Exchanger<String> exchanger;
    
    MyTask2(Exchanger<String> exchanger) {
      this.exchanger = exchanger;
    }
    
    @Override
    public void run() {
      String str = null;
      try {
        str = exchanger.exchange("Hello from MyTask2");
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println("Received in MyTask2 = " + str);
    }
    
  }
  
  public static void main(String[] args) {
    
    Exchanger<String> exchanger = new Exchanger<String>();
    
    Thread t1 = new Thread(new MyTask1(exchanger));
    Thread t2 = new Thread(new MyTask2(exchanger));
    t1.start();
    t2.start();
  }
}
This program produces the following output.
Received in MyTask2 = Hello from MyTask1
Received in MyTask1 = Hello from MyTask2
Read other concurrency tutorials from Java Tutorials page.
  • Share This:  
Newer Post Older Post Home

0 comments:

Post a Comment

Follow @StackStalk
Get new posts by email:
Powered by follow.it

Popular Posts

  • Avro Producer and Consumer with Python using Confluent Kafka
    In this article, we will understand Avro a popular data serialization format in streaming data applications and develop a simple Avro Produc...
  • Monitor Spring Boot App with Micrometer and Prometheus
    Modern distributed applications typically have multiple microservices working together. Ability to monitor and manage aspects like health, m...
  • Server-Sent Events with Spring WebFlux
    In this article we will review the concepts of server-sent events and work on an example using WebFlux. Before getting into this article it ...
  • Implement caching in a Spring Boot microservice using Redis
    In this article we will explore how to use Redis as a data cache for a Spring Boot microservice using PostgreSQL as the database. Idea is to...
  • Python FastAPI microservice with Okta and OPA
    Authentication (AuthN) and Authorization (AuthZ) is a common challenge when developing microservices. In this article, we will explore how t...
  • Spring Boot with Okta and OPA
    Authentication (AuthN) and Authorization (AuthZ) is a common challenge when developing microservices. In this article, we will explore how t...
  • Getting started with Kafka in Python
    This article will provide an overview of Kafka and how to get started with Kafka in Python with a simple example. What is Kafka? ...
  • Getting started in GraphQL with Spring Boot
    In this article we will explore basic concepts on GraphQL and look at how to develop a microservice in Spring Boot with GraphQL support. ...

Copyright © StackStalk