bomberlhl

synchronized(欲同步的對(duì)象obj) {
需要同步的代碼塊
}

public class HelloSynchronized {
public static void main(String[] args) {
//
HelloSynchronized helloSynchronized = new HelloSynchronized();
//創(chuàng)建2個(gè)線程t1, t2，分別調(diào)用HelloSynchronized helloSynchronized的2個(gè)方法method1，與method2
Thread t1 = new Thread(new HelloSynchronizedRunnalbe(helloSynchronized, "method1"), "t1");
Thread t2 = new Thread(new HelloSynchronizedRunnalbe(helloSynchronized, "method2"), "t2");
t1.start();
t2.start();
}
//synchronized public void method1() {    //同步方法
public void method1() {
synchronized (this) {    //同步塊
System.out.println(Thread.currentThread().getName()
+ " enter method1");
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
// do nothing
}
System.out.println(Thread.currentThread().getName()
+ " exit method1");
}
}
//synchronized public void method2() {    //同步方法
public void method2() {
synchronized (this) {    //同步塊
System.out.println(Thread.currentThread().getName()
+ " enter method2");
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
// do nothing
}
System.out.println(Thread.currentThread().getName()
+ " exit method2");
}
}
}
class HelloSynchronizedRunnalbe implements Runnable {
private HelloSynchronized helloSynchronized;
private String methodName;
public HelloSynchronizedRunnalbe(HelloSynchronized helloSynchronized, String methodName) {
this.helloSynchronized = helloSynchronized;
this.methodName = methodName;
}
public void run() {
if (methodName.equals("method1")) {
helloSynchronized.method1();
} else if (methodName.equals("method2")) {
helloSynchronized.method2();
}
}
}

synchronized private void sellBook(Book book) {
...
}

private void sellBook(Book book) {
synchronized(this) {
...
}
}

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;
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 (book)保證book不被其他售貨員售出
synchronized (book) {
if (book.isSold()) {
return;
} else {
try {
//為了讓各線程有執(zhí)行機(jī)會(huì)，設(shè)置平均售書時(shí)間為0.5秒
Thread.sleep(500);
} catch (Exception e) {
}
//設(shè)置已售標(biāo)志
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 (book)保證book不被其他售貨員售出
synchronized (book) {
if (book.isSold()) {
return;
} else {
try {
//為了讓各線程有執(zhí)行機(jī)會(huì)，設(shè)置平均售書時(shí)間為0.5秒
Thread.sleep(500);
} catch (Exception e) {
}
//設(shè)置已售標(biāo)志
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;
//該類調(diào)用SellBookXxx類
public class CallSellBook {
/**
* 用線程模擬這個(gè)售書的過程
*/
public static void main(String[] args) {
//方法1：
callSellBookThread();
//or
//方法2：
//callSellBookRunnable();
}
//調(diào)用SellBookRunnable（Runnable接口實(shí)現(xiàn)類）模擬售書過程
public static void callSellBookThread() {
List <Book>bookList = getBookListForSale();
//將預(yù)售書籍清單交給售貨員SaleMan1
Thread t1 = new SellBookThread("SaleMan1", bookList);
//將預(yù)售書籍清單交給售貨員SaleMan2
Thread t2 = new SellBookThread("SaleMan2", bookList);
//售貨員SaleMan1開始售書
t1.start();
//售貨員SaleMan2開始售書
t2.start();
}
//調(diào)用SellBookRunnable（Runnable接口實(shí)現(xiàn)類）模擬售書過程
public static void callSellBookRunnable() {
List <Book>bookList = getBookListForSale();
//將預(yù)售書籍清單交給售貨員SaleMan1
Thread t1 = new Thread(new SellBookRunnable("SaleMan1", bookList));
//將預(yù)售書籍清單交給售貨員SaleMan2
Thread t2 = new Thread(new SellBookRunnable("SaleMan2", bookList));
//售貨員SaleMan1開始售書
t1.start();
//售貨員SaleMan2開始售書
t2.start();
}
//準(zhǔn)備預(yù)售書籍
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;
}
}