定義運行方法
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(); }}