package JavaBasic;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* @Classname SynLock
* @Description 使用Lock对象æ¥å®žçŽ°åŒæ¥æœºåˆ¶
* @Date 19-5-25 下åˆ4:04
* @Created by mao
*/
class Callme_1{
private Lock lock=new ReentrantLock();
void call(String msg){
lock.lock();
try{
System.out.print("lock: ["+msg);
try{
Thread.sleep(1000);
}catch (InterruptedException e){
System.out.println("Interrupted");
}
System.out.println("]");
}finally {
lock.unlock();
}
}
}
class Caller_1 implements Runnable{
String msg;
Callme_1 target;
Thread t;
public Caller_1(Callme_1 tar,String s){
target=tar;
msg=s;
t=new Thread(this);
t.start();
}
public void run(){
target.call(msg);
}
}
public class SynLock {
public static void main(String[] args){
Callme_1 target=new Callme_1();
//没有组织三个线程åŒæ—¶è°ƒç”¨åŒä¸€ä¸ªå¯¹è±¡çš„åŒä¸€ä¸ªæ–¹æ³•,在callå‰é¢åŠ 上synchronized关键å—
Caller_1 ob1=new Caller_1(target,"hello");
Caller_1 ob2=new Caller_1(target,"synchronized");
Caller_1 ob3=new Caller_1(target,"world");
try {
ob1.t.join();
ob2.t.join();
ob3.t.join();
}catch (InterruptedException e){
System.out.println("interrupted");
}
}
}