java线程锁基础

定义运行方法

package com.company;  // 包名
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.Lock;
public class ticket implements Runnable{
    private int ticketnum = 100;                    //全局变量
    Lock lock = new ReentrantLock(true);            //对象
    @Override
    public void run() {                             //写 run（）
        while (ticketnum > 0){
            lock.lock();                            //加锁
            try {
                if (ticketnum > 0){
                    try {
                        Thread.sleep(100);             //工作时间
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    String name = new Thread().currentThread().getName();
                    System.out.println("线程"+name+"销售电影票"+ticketnum--);
                }
            }
            finally {
                lock.unlock();                     //解锁
            }
        }
    }
}


将方法加入到线程中

package com.company;import com.company.ticket;public class shoupiao {    public static void main(String[] args) {        ticket ticket = new ticket();        Thread thread1 = new Thread(ticket,"窗口1");        Thread thread2 = new Thread(ticket,"窗口2");        Thread thread3 = new Thread(ticket,"窗口3");        thread1.start();        thread2.start();        thread3.start();    }}