サンプルから学ぶJava スレッド及びスレッドの同期

public class Book {
    private String name;
    private boolean sold = false;

    public Book(String name) {
        this.name = name;
    }
    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public boolean isSold() {
        return sold;
    }

    public void setSold(boolean sold) {
        this.sold = sold;
    }
}

import java.util.List;

//Runnableインタフェース実装
public class SellBookRunnable implements Runnable {
    private String saleMan;    //店員
    private List<Book> bookList;    //売る対象となる本のリスト

    public SellBookRunnable(String saleMan, List<Book> bookList) {
        this.saleMan = saleMan;
        this.bookList = bookList;
    }

    public void run() {
        for (int i = 0; i < bookList.size(); i++) {
            Book book = bookList.get(i);
            sellBook(book);
        }
    }

    /**
     * 本を売る
     * 
     * @param book Book
     */
    private void sellBook(Book book) {
        //synchronizedを利用してスレッドの同期を取ります。synchronized (book)でbookは他の店員に取られないように制御します。
        synchronized (book) {
            if (book.isSold()) {    //既に売った場合
                return;
            } else {
                try {
                    //他のスレッドに実行されるチャンスを与えるため、0.5秒をあけます「本を取った時点から売ったまでの時間」。
                    Thread.sleep(500);
                } catch (Exception e) {
                }
                
                //売り出したとのフラグを設定します
                book.setSold(true);
                //売りましたよ
                System.out.println("[" + saleMan + "]" + book.getName() + " sold out:"
                        + book.isSold() + ". by "
                        + Thread.currentThread().getName());

            }
        }
    }
}

import java.util.List;

public class SellBookThread extends Thread {
    private String saleMan;
    private List<Book> bookList;

    public SellBookThread(String saleMan, List<Book> bookList) {
        this.saleMan = saleMan;
        this.bookList = bookList;
    }

    public void run() {
        for (int i = 0; i < bookList.size(); i++) {
            Book book = bookList.get(i);
            sellBook(book);
        }
    }

    /**
     * 本を売る
     * 
     * @param book Book
     */
    private void sellBook(Book book) {
        //synchronizedを利用してスレッドの同期を取ります。synchronized (book)でbookは他の店員に取られないように制御します。
        synchronized (book) {
            if (book.isSold()) {    //既に売った場合
                return;
            } else {
                try {
                    //他のスレッドに実行されるチャンスを与えるため、0.5秒をあけます「本を取った時点から売ったまでの時間」。
                    Thread.sleep(500);
                } catch (Exception e) {
                }
                
                //売り出したとのフラグを設定します
                book.setSold(true);
                //売りましたよ
                System.out.println("[" + saleMan + "]" + book.getName() + " sold out:"
                        + book.isSold() + ". by "
                        + Thread.currentThread().getName());

            }
        }
    }
}

import java.util.ArrayList;
import java.util.List;

//スレッドの生成、実行
public class CallSellBook {

    /**
     * マルチスレッドで「本を売る」ことをシミュレーションします
     */
    public static void main(String[] args) {
        //方法１
        callSellBookThread();

        //or
        
        //方法２
        //callSellBookRunnable();
    }
    
    //本を売る
    //SellBookThread（Threadクラスの実装）を利用します
    public static void callSellBookThread() {
        List <Book>bookList = getBookListForSale();    //売る対象となる本リスト
        
        //店員SaleMan1
        Thread t1 = new SellBookThread("SaleMan1", bookList);
        //店員SaleMan2
        Thread t2 = new SellBookThread("SaleMan2", bookList);

        //店員SaleMan1：「本を売る」処理開始
        t1.start();
        //店員SaleMan２：「本を売る」処理開始
        t2.start();
    }
    
    
    //本を売る
    //SellBookRunnable（Runnableインタフェースの実装）を利用します
    public static void callSellBookRunnable() {
        List <Book>bookList = getBookListForSale();    //売る対象となる本リスト
        
        //店員SaleMan1
        Thread t1 = new Thread(new SellBookRunnable("SaleMan1", bookList));
        //店員SaleMan2
        Thread t2 = new Thread(new SellBookRunnable("SaleMan2", bookList));

        //店員SaleMan1：「本を売る」処理開始
        t1.start();
        //店員SaleMan２：「本を売る」処理開始
        t2.start();
    }

    //売る対象となる本リスト
    public static List<Book> getBookListForSale() {
        List <Book>bookList = new ArrayList();
        for (int i = 0; i < 20; i++) {
            Book book = new Book("Book" + i);
            bookList.add(book);
        }
        
        return bookList;
    }
}