定义运行方法

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();
    }
}