Implementing a Thread-Safe Configuration Manager with ReentrantReadWriteLock

Introduction to Thread-Safe Configuration Manager with ReentrantReadWriteLock

Hello, and welcome back! In our previous lessons, we explored concurrent collections such as ConcurrentHashMap and CopyOnWriteArrayList, learning to safely manage data across multiple threads. Today, we'll build on that foundation with the concept of thread-safe management of configurations using ReentrantReadWriteLock . In multi-threaded systems, it's common for configurations to be read frequently and updated occasionally. To optimize performance, we can allow multiple threads to read configurations concurrently while ensuring that only one thread can write (update) at a time. This is where ReentrantReadWriteLock comes in.

What You'll Learn

By the end of this lesson, you will: Gain an understanding of ReentrantReadWriteLock and how it differs from regular locks. Implement a configuration manager that allows concurrent reads and exclusive writes. Learn to balance data consistency and performance in multi-threaded environments. These skills are essential for developers managing configurations in systems where read-heavy operations occur alongside occasional updates.

Understanding ReentrantReadWriteLock

Before we dive into the implementation, let’s take a closer look at ReentrantReadWriteLock . ReentrantReadWriteLock is a specialized lock that provides two types of locks: Read Lock : Multiple threads can hold the read lock simultaneously. This allows for concurrent reads without blocking each other, enhancing performance when reading data frequently. Write Lock : Only one thread can hold the write lock at a time. This ensures that no other thread can read or write to the data while the write lock is held, preserving data integrity during modifications. Unlike a simple ReentrantLock, which provides a single lock for both reading and writing, ReentrantReadWriteLock distinguishes between read and write operations. This allows for greater concurrency in read-heavy systems while still ensuring exclusive access when writing data. The general behavior of ReentrantReadWriteLock is as follows: Read Lock : Can be held by multiple threads as long as no thread holds the write lock. Write Lock : Can be held by only one thread at a time, and no threads can hold the read lock while the write lock is active. This dual-lock mechanism helps achieve an optimal balance between performance and safety in applications where reading occurs frequently, but writing happens occasionally.

Join the 1M+ learners on CodeSignal

Be a part of our community of 1M+ users who develop and demonstrate their skills on CodeSignal

Java

import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.HashMap;
import java.util.Map;

public class ConfigurationManager {
    private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
    private final Map<String, String> config = new HashMap<>();
}

import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.HashMap;
import java.util.Map;

public class ConfigurationManager {
    private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
    private final Map<String, String> config = new HashMap<>();
}

Java

public void setProperty(String key, String value) {
    lock.writeLock().lock();  // Acquire the write lock
    try {
        config.put(key, value);  // Modify the configuration
        System.out.println("Set " + key + " = " + value);
    } finally {
        lock.writeLock().unlock();  // Always release the lock in a finally block
    }
}

public void setProperty(String key, String value) {
    lock.writeLock().lock();  // Acquire the write lock
    try {
        config.put(key, value);  // Modify the configuration
        System.out.println("Set " + key + " = " + value);
    } finally {
        lock.writeLock().unlock();  // Always release the lock in a finally block
    }
}

Java

public String getProperty(String key) {
    lock.readLock().lock();  // Acquire the read lock
    try {
        return config.get(key);  // Retrieve the configuration
    } finally {
        lock.readLock().unlock();  // Always release the lock in a finally block
    }
}

public String getProperty(String key) {
    lock.readLock().lock();  // Acquire the read lock
    try {
        return config.get(key);  // Retrieve the configuration
    } finally {
        lock.readLock().unlock();  // Always release the lock in a finally block
    }
}

Java

public class Main {
    public static void main(String[] args) throws InterruptedException {
        ConfigurationManager configManager = new ConfigurationManager();

        Thread writer = new Thread(() -> {
            configManager.setProperty("URL", "http://example.com");
            configManager.setProperty("Timeout", "5000");
        });

        Thread reader1 = new Thread(() -> {
            String url = configManager.getProperty("URL");
            System.out.println("Reader1 read URL: " + url);
        });

        Thread reader2 = new Thread(() -> {
            String timeout = configManager.getProperty("Timeout");
            System.out.println("Reader2 read Timeout: " + timeout);
        });

        writer.start();
        writer.join();

        reader1.start();
        reader2.start();

        reader1.join();
        reader2.join();
    }
}

public class Main {
    public static void main(String[] args) throws InterruptedException {
        ConfigurationManager configManager = new ConfigurationManager();

        Thread writer = new Thread(() -> {
            configManager.setProperty("URL", "http://example.com");
            configManager.setProperty("Timeout", "5000");
        });

        Thread reader1 = new Thread(() -> {
            String url = configManager.getProperty("URL");
            System.out.println("Reader1 read URL: " + url);
        });

        Thread reader2 = new Thread(() -> {
            String timeout = configManager.getProperty("Timeout");
            System.out.println("Reader2 read Timeout: " + timeout);
        });

        writer.start();
        writer.join();

        reader1.start();
        reader2.start();

        reader1.join();
        reader2.join();
    }
}

Java

import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.HashMap;
import java.util.Map;

public class ConfigurationManager {
    private final ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
    private final Map<String, String> config = new HashMap<>();
}

Java

public void setProperty(String key, String value) {
    lock.writeLock().lock();  // Acquire the write lock
    try {
        config.put(key, value);  // Modify the configuration
        System.out.println("Set " + key + " = " + value);
    } finally {
        lock.writeLock().unlock();  // Always release the lock in a finally block
    }
}

Java

public String getProperty(String key) {
    lock.readLock().lock();  // Acquire the read lock
    try {
        return config.get(key);  // Retrieve the configuration
    } finally {
        lock.readLock().unlock();  // Always release the lock in a finally block
    }
}

Java

public class Main {
    public static void main(String[] args) throws InterruptedException {
        ConfigurationManager configManager = new ConfigurationManager();

        Thread writer = new Thread(() -> {
            configManager.setProperty("URL", "http://example.com");
            configManager.setProperty("Timeout", "5000");
        });

        Thread reader1 = new Thread(() -> {
            String url = configManager.getProperty("URL");
            System.out.println("Reader1 read URL: " + url);
        });

        Thread reader2 = new Thread(() -> {
            String timeout = configManager.getProperty("Timeout");
            System.out.println("Reader2 read Timeout: " + timeout);
        });

        writer.start();
        writer.join();

        reader1.start();
        reader2.start();

        reader1.join();
        reader2.join();
    }
}

Introduction to Thread-Safe Configuration Manager with ReentrantReadWriteLock

What You'll Learn

Understanding ReentrantReadWriteLock

Join the 1M+ learners on CodeSignal

Implementing the Configuration Manager

Setting Properties with Write Lock

Getting Properties with Read Lock

Managing Threads in the Main Application

Why It Matters