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();    }}
相關文章
相關標籤/搜索