Pacific-Design.com

    
Home Index

1. Java

2. Concurrency

+ Synchronized

+ Wait Notify

Java / Concurrency /

Java Thread with multiple Object locks


import java.util.ArrayList;
import java.util.List;
import java.util.Random;
 
 
public class Worker {
     
    private Random random = new Random();
     
    private Object lock1 = new Object();
    private Object lock2 = new Object();
     
    private List list1 = new ArrayList();
    private List list2 = new ArrayList();
     
    public void stageOne() {
         
        synchronized (lock1) {
            try {
                Thread.sleep(1);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
             
            list1.add(random.nextInt(100));
        }
     
    }
     
    public void stageTwo() {
         
        synchronized (lock2) {
            try {
                Thread.sleep(1);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
             
            list2.add(random.nextInt(100));
        }
         
    }
     
    public void process() {
        for(int i=0; i<1000; i++) {
            stageOne();
            stageTwo();
        }
    }
 
    public void main() {
        System.out.println("Starting ...");
         
        long start = System.currentTimeMillis();
         
        Thread t1 = new Thread(new Runnable() {
            public void run() {
                process();
            }
        });
         
        Thread t2 = new Thread(new Runnable() {
            public void run() {
                process();
            }
        });
         
        t1.start();
        t2.start();
         
        try {
            t1.join();
            t2.join();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
         
        long end = System.currentTimeMillis();
         
        System.out.println("Time taken: " + (end - start));
        System.out.println("List1: " + list1.size() + "; List2: " + list2.size());
    }
}

public class App {
 
    public static void main(String[] args) {
        Worker worker = new Worker();
        worker.main();
 
    }
}