线程同步方法

1.继承Thread，同步锁

package java11.同步.Thread;

public class Ticket extends Thread {
    
    static int ticket = 100;
    static Object o = new Object();

    @Override
    public void run() {
    
        while (true) {
    
            //同步锁
            synchronized (o) {
    
                if (ticket > 0) {
    
                    System.out.println(Thread.currentThread().getName() + ticket);
                    ticket--;
                } else {
    
                    break;
                }
            }
            try {
    
                sleep(1000);
            } catch (InterruptedException e) {
    
                e.printStackTrace();
            }
        }
    }
}

package java11.同步.Thread;

public class Test01 {
    
    public static void main(String[] args) {
    
        Ticket t = new Ticket();
        Ticket t1 = new Ticket();
        Ticket t2 = new Ticket();

        t.setName("晓晓");
        t1.setName("小小");
        t2.setName("晓");

        t.start();
        t1.start();
        t2.start();
    }
}

2.实现Runnable，同步锁

package java11.同步.Runnable;

public class Ticket implements Runnable {
    
    int ticket = 100;

    @Override
    public void run() {
    
        while (true) {
    
            //同步锁
            synchronized (this) {
    
                if (ticket > 0) {
    
                    System.out.println(Thread.currentThread().getName() + ticket);
                    ticket--;
                } else {
    
                    break;
                }
            }
            try {
    
                Thread.sleep(1000);
            } catch (InterruptedException e) {
    
                e.printStackTrace();
            }
        }
    }
}

package java11.同步.Runnable;

public class Test01 {
    
    public static void main(String[] args) {
    
        Ticket ticket = new Ticket();
        Thread t = new Thread(ticket);
        Thread t1 = new Thread(ticket);
        Thread t2 = new Thread(ticket);

        t.setName("晓晓");
        t1.setName("小小");
        t2.setName("晓");

        t.start();
        t1.start();
        t2.start();
    }
}

3.实现Runnable的同步方法

package java11.同步.同步方法;

public class Ticket implements Runnable {
    
    int ticket = 100;

    @Override
    public void run() {
    
        while (true) {
    
            if (ticket > 0) {
    
                sell();
            }
            try {
    
                Thread.sleep(1000);
            } catch (InterruptedException e) {
    
                e.printStackTrace();
            }
        }
    }

    //同步方法
    public synchronized void sell() {
    
        if (ticket > 0) {
    
            System.out.println(Thread.currentThread().getName() + ticket);
            ticket--;
        }
    }
}

package java11.同步.同步方法;

public class Test01 {
    
    public static void main(String[] args) {
    
        Ticket ticket = new Ticket();
        Thread t = new Thread(ticket);
        Thread t1 = new Thread(ticket);
        Thread t2 = new Thread(ticket);

        t.setName("晓晓");
        t1.setName("小小");
        t2.setName("晓");

        t.start();
        t1.start();
        t2.start();
    }
}

4.实现Runnable，Collections.synchronizedList

package java11.同步.练习;

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

public class MyThread implements Runnable {
    
    List l = Collections.synchronizedList(new ArrayList());

    @Override
    public void run() {
    
        for (int i = 0; i < 100; i++) {
    
            l.add(i);
        }
    }
}

package java11.同步.练习;

public class Test01 {
    
    public static void main(String[] args) throws InterruptedException {
    
        MyThread m = new MyThread();
        Thread t = new Thread(m);
        Thread t1 = new Thread(m);

        t.start();
        t1.start();

        t.join();
        t1.join();

        System.out.println(m.l.size());
    }
}