线程同步,synhronized,锁

Question

要求主线程执行100次，子线程执行10次，主线程执行100次，子线程执行10次。。。循环代码如下：public class Test_02 {public static void main(String[] args){        MeThread me = new MeThread();    Thread t = new Thread(me);    t.start();    boolean flag = true;    int i = 1;    synchronized (me) {                while (flag) {            System.out.println(Thread.currentThread().getName() + i);            i++;            if (i % 100 == 0) {                try {                    Thread.currentThread().wait();                } catch (InterruptedException e) {                                        e.printStackTrace();                }finally {                    System.out.println("===========");                    me.notify();//Thread.currentThread().notifyAll();也不行                }            }        }    }}}class MeThread implements Runnable {@Overridepublic synchronized void run() {int i = 0;    boolean flag = true;    while (flag) {        System.out.println(Thread.currentThread().getName() + i);        i++;        if (i % 10 == 0) {            try {                Thread.currentThread().wait();            } catch (InterruptedException e) {                                e.printStackTrace();            }finally {                System.out.println("===========");                                this.notify();//Thread.currentThread().notifyAll();也不行            }        }    }}}

Answer 1

public class Test_02 {

public static void main(String[] args) {

    MeThread me = new MeThread();

    Thread t = new Thread(me);

    t.start();

    boolean flag = true;

    //修改了初始值

    int i = 0;

    synchronized (me) {

        while (flag) {

            System.out.println(Thread.currentThread().getName() + i);

            i++;

            if (i % 100 == 0) {

                try {

                    //方便观察效果,睡眠1s

                    Thread.sleep(1000);

                    System.out.println("main===========");

                    //从finally代码块中前移到wait()方法前

                    me.notify();

                    //锁对象为me

                    me.wait();

                } catch (InterruptedException e) {

                    e.printStackTrace();

                }

            }

        }

    }

}

}

class MeThread implements Runnable {

@Override

public synchronized void run() {

int i = 0;

    boolean flag = true;

    while (flag) {

        System.out.println(Thread.currentThread().getName() + i);

        i++;

        if (i % 10 == 0) {

            try {

                //方便观察

                Thread.sleep(1000);

                System.out.println("MeThread===========");

                //同步方法锁对象为this,notify()移动到wait()方法前

                this.notify();

                //同步方法锁对象为this

                this.wait();

            } catch (InterruptedException e) {

                e.printStackTrace();

            } 

        }

    }

}

}

Answer 2

平时项目开发的时候这个多线程用在哪里？怎么使用？