How to Create Thread in Java: Complete Guide with Best Practices | 2026 Guide

Practical Code Examples for Creating Threads in Java

Method 1: Implementing Runnable (Recommended)

// Create a class implementing Runnable
public class MyThread implements Runnable {
    private String threadName;
    
    public MyThread(String name) {
        this.threadName = name;
    }
    
    @Override
    public void run() {
        try {
            for (int i = 0; i < 5; i++) {
                System.out.println(threadName + ": " + i);
                Thread.sleep(1000);
            }
        } catch (InterruptedException e) {
            System.err.println("Thread interrupted: " + e.getMessage());
            Thread.currentThread().interrupt();
        }
    }
}

// Create and start the thread
public class ThreadCreationExample {
    public static void main(String[] args) {
        // Create thread object
        Thread thread1 = new Thread(new MyThread("Thread-1"));
        Thread thread2 = new Thread(new MyThread("Thread-2"));
        
        // Start threads
        thread1.start();
        thread2.start();
    }
}

Method 2: Using ExecutorService (Production Standard)

import java.util.concurrent.*;

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // Create a thread pool with 4 threads
        ExecutorService executor = Executors.newFixedThreadPool(4);
        
        try {
            // Submit tasks to the executor
            for (int i = 0; i < 10; i++) {
                executor.submit(() -> {
                    String threadName = Thread.currentThread().getName();
                    System.out.println("Executing task in " + threadName);
                });
            }
        } finally {
            // Always shutdown the executor
            executor.shutdown();
            if (!executor.awaitTermination(5, TimeUnit.SECONDS)) {
                executor.shutdownNow();
            }
        }
    }
}

Method 3: Virtual Threads (Java 21+)

import java.util.concurrent.*;

public class VirtualThreadExample {
    public static void main(String[] args) throws InterruptedException {
        // Create virtual thread executor
        ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor();
        
        try {
            for (int i = 0; i < 100; i++) {
                executor.submit(() -> {
                    System.out.println("Running in " + Thread.currentThread());
                });
            }
        } finally {
            executor.shutdown();
            executor.awaitTermination(10, TimeUnit.SECONDS);
        }
    }
}