查漏补缺

package cn.soldier.oop;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

//创建Thread，小秀一手
public class ThreadDemo {
    public static void main(String[] args) {

        new TestThread("逗比 ").start();
        new TestThread("呵呵 hehe").start();

        //
        for (int i = 0; i < 100; i++) {
            System.out.println("ThreadDemo.main() -------- " + i);
        }

    }
}

class TestThread extends Thread {

    TestThread(String name) {
        super(name);
    }

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println(this.getName()
                    + "-------TestThread.run() -------- " + i);
        }
    }

}

// 实现Runnable接口，使用synchronized解决多个线程操作共享数据的安全问题
public class ThreadDemo {
    public static void main(String[] args) {
        TickeRunnable tickeRunnable = new TickeRunnable();
        new Thread(tickeRunnable).start();
        new Thread(tickeRunnable).start();
    }
}

// class TickeThread extends Thread {
class TickeRunnable implements Runnable {

    private int tick = 100;
    Object obj = new Object();

    public void run() {
        boolean flag = true;
        while (flag) {
            synchronized (obj) {
                if (tick > 0) {
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                    }
                    System.out.println("Ticke:  " + tick-- + "号，被   "
                            + Thread.currentThread().getName() + "  卖了");
                } else {
                    flag = false;
                }
            }
        }
    }
}

public class ThreadDemo {
    public static void main(String[] args) {
        Cus cus = new Cus();
        new Thread(cus).start();
        new Thread(cus).start();
    }
}

class Bank {
    private int sum;

    public void add(int n) {
        synchronized (this) {
            sum = sum + n;
            System.out.println(Thread.currentThread().getName()
                    + "  Bank.add()--- sum=" + sum);
        }
    }
}

class Cus implements Runnable {
    private Bank bank = new Bank();

    public void run() {
        for (int i = 0; i < 3; i++) {
            bank.add(100);
        }
    }
}

// 延迟加载的单例模式
class Single {
    private static Single s = null;

    private Single() {
    }

    public static Single getInStance() {

        if (s == null) {
            // 这是关键，减少同步次数，提高效率
            synchronized (Single.class) {
                // 锁。该类所属的字节码文件对象
                if (s == null) {
                    s = new Single();
                }
            }
        }
        return s;
    }
}

// 饿汉试单例模式
class Single1 {
    private static final Single1 s = new Single1();

    private Single1() {
    }

    public static Single1 getInStance() {
        return s;
    }
}

// 死锁
public class ThreadDemo {
    public static void main(String[] args) {
        new Thread(new Testlock(true)).start();
        new Thread(new Testlock(false)).start();
    }
}

class Testlock implements Runnable {
    private boolean flag;

    Testlock(boolean flag) {
        this.flag = flag;
    }

    public void run() {

        if (flag) {
            synchronized (Mylock.locka) {
                System.out.println("if locka");
                synchronized (Mylock.lockb) {
                    System.out.println("if lockb");
                }
            }

        } else {
            synchronized (Mylock.lockb) {
                System.out.println("else lockb");
                synchronized (Mylock.locka) {
                    System.out.println("else locka");
                }
            }

        }
    }
}

class Mylock {
    static Object locka = new Object();
    static Object lockb = new Object();
}

public class ThreadDemo {
    public static void main(String[] args) {

        Resource resource = new Resource();
        Producer producer = new Producer(resource);
        Consumer consumer = new Consumer(resource);

        new Thread(producer).start();
        new Thread(consumer).start();
        new Thread(producer).start();
        new Thread(consumer).start();

    }
}

class Resource {
    private String name;
    private int count = 1;
    private boolean flag = false;

    public synchronized void set(String name) {
        while (flag) {
            try {
                this.wait();
            } catch (Exception e) {
            }
        }
        this.name = name + "--" + count++;
        System.out.println(Thread.currentThread().getName() + "--生产者--"
                + this.name);
        flag = true;
        this.notifyAll();

    }

    public synchronized void out() {
        while (!flag) {
            try {
                this.wait();
            } catch (Exception e) {
            }
        }
        System.out.println(Thread.currentThread().getName()
                + "--------消费者-------" + this.name);
        flag = false;
        this.notifyAll();

    }
}

class Producer implements Runnable {
    private Resource resource;

    Producer(Resource resource) {
        this.resource = resource;
    }

    public void run() {
        while (true) {
            resource.set("逗比");

        }
    }
}

class Consumer implements Runnable {
    private Resource resource;

    Consumer(Resource resource) {
        this.resource = resource;
    }

    public void run() {
        while (true) {
            resource.out();
        }
    }
}

public class ThreadDemo {
    public static void main(String[] args) {

        Resource resource = new Resource();
        Producer producer = new Producer(resource);
        Consumer consumer = new Consumer(resource);

        new Thread(producer).start();
        new Thread(consumer).start();
        new Thread(producer).start();
        new Thread(consumer).start();

    }
}

class Resource {
    private final Lock lock = new ReentrantLock();// 拿到锁
    private final Condition condition_producer = lock.newCondition();// 生产者的监视器
    private final Condition condition_consumer = lock.newCondition();// 消费者的监视器
    //
    private String name;
    private int count = 1;
    private boolean flag = false;

    public void set(String name) throws InterruptedException {
        lock.lock();
        try {
            if (flag)
                condition_producer.await();
            this.name = name + "--" + count++;
            System.out.println(Thread.currentThread().getName() + "--生产者--"
                    + this.name);
            flag = true;
            condition_consumer.signal();
        } finally {
            lock.unlock();
        }
    }

    public void out() throws InterruptedException {
        lock.lock();
        try {
            if (!flag)
                condition_consumer.await();
            System.out.println(Thread.currentThread().getName()
                    + "--------消费者-------" + this.name);
            flag = false;
            condition_producer.signal();
        } finally {
            lock.unlock();
        }

    }
}

class Producer implements Runnable {
    private Resource resource;

    Producer(Resource resource) {
        this.resource = resource;
    }

    public void run() {
        while (true) {
            try {
                resource.set("逗比");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    }
}

class Consumer implements Runnable {
    private Resource resource;

    Consumer(Resource resource) {
        this.resource = resource;
    }

    public void run() {
        while (true) {
            try {
                resource.out();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}