Building a Simple Multithreaded Application

Welcome back to our journey into Java concurrency! So far, you've learned about creating threads, managing their lifecycle, and synchronizing shared data. Today, we will apply these concepts by building a simple multithreaded application. This project will give you practical experience with real-world concurrency in Java and demonstrate how to use synchronization effectively for safe data sharing.

What You'll Learn

In this project, you will: Implement a class that simulates a file download operation. Create and manage multiple threads to perform concurrent downloads. Use thread synchronization to manage output and prevent message overlap. Set thread priorities and observe their impact on thread scheduling. By the end of this project, you'll have the skills to build a basic multithreaded application and understand key concurrency concepts in a practical setting.

Project Overview: Multithreaded File Downloader

You will create a Downloader class that simulates file downloads. The class will implement the Runnable interface, allowing it to be run by multiple threads. A Main class will manage these threads and coordinate their completion.

Implementing the Downloader Class

First, we'll create a Downloader class to simulate the downloading process. This class will implement the Runnable interface to be run within threads. We will split its implementation for clarity.

Fields and Constructor

Java import java.util.Random; public class Downloader implements Runnable {private final String fileName; private final Random rnd; public Downloader(String fileName) {this.fileName = fileName; this.rnd = new Random();}} In this snippet, we declare the class fields: fileName, which holds the name of the file to be downloaded, and rnd, a Random object used to simulate variable download times. The constructor initializes these fields, setting up the Downloader instance with the specified file name.

Join the 1M+ learners on CodeSignal

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

Step 2: Managing Downloader Threads

Next, we'll create a Main class to manage multiple downloader threads. We'll start the threads, set their priorities, and ensure that the main thread waits for their completion.

Java

public class Main {
    public static void main(String[] args) throws InterruptedException {
        // Creating downloader threads
        Thread t1 = new Thread(new Downloader("file1.txt"));
        Thread t2 = new Thread(new Downloader("file2.txt"));
        Thread t3 = new Thread(new Downloader("file3.txt"));

        // Setting thread names for better identification
        t1.setName("Downloader-1");
        t2.setName("Downloader-2");
        t3.setName("Downloader-3");

        // Setting different priorities to illustrate effect on scheduling (optional, depends on JVM)
        t1.setPriority(Thread.MAX_PRIORITY);
        t2.setPriority(Thread.NORM_PRIORITY);
        t3.setPriority(Thread.MIN_PRIORITY);

        // Start all threads
        t1.start();
        t2.start();
        t3.start();

        // Use join to ensure main thread waits for all download threads to finish
        t1.join();
        t2.join();
        t3.join();

        // Indicate that all downloads are complete
        System.out.println("All downloads completed");
    }
}

public class Main {
    public static void main(String[] args) throws InterruptedException {
        // Creating downloader threads
        Thread t1 = new Thread(new Downloader("file1.txt"));
        Thread t2 = new Thread(new Downloader("file2.txt"));
        Thread t3 = new Thread(new Downloader("file3.txt"));

        // Setting thread names for better identification
        t1.setName("Downloader-1");
        t2.setName("Downloader-2");
        t3.setName("Downloader-3");

        // Setting different priorities to illustrate effect on scheduling (optional, depends on JVM)
        t1.setPriority(Thread.MAX_PRIORITY);
        t2.setPriority(Thread.NORM_PRIORITY);
        t3.setPriority(Thread.MIN_PRIORITY);

        // Start all threads
        t1.start();
        t2.start();
        t3.start();

        // Use join to ensure main thread waits for all download threads to finish
        t1.join();
        t2.join();
        t3.join();

        // Indicate that all downloads are complete
        System.out.println("All downloads completed");
    }
}

The Main class manages multiple downloader threads, each downloading a different file. The threads are given unique names for better identification, and we set different priorities for each thread to illustrate scheduling differences. Finally, we use join() to ensure that the main thread waits for all download threads to complete before continuing, providing clear, sequential output.