| |
四种方式 sychronized关键字 sychronized method(){} sychronized (objectreference) {/*block*/} static synchronized method(){} sychronized(classname.class) 其中1和2是代表锁当前对象,即一个对象就一个锁,3和4代表锁这个类,即这个类的锁 要注意的是sychronized method()不是锁这个函数,而是锁对象,即:如果这个类中有两个方法都是sychronized,那么只要有两个线程共享一个该类的reference,每个调用这两个方法之一,不管是否同一个方法,都会用这个对象锁进行同步。锁类的3和4类推,即该类的不同reference调用了sychronized区段的咚咚就会受类锁的控制 还有,如果两个函数调用的先后顺序不能被打断,那么可以有个专门的锁对象来完成这个任务: class mylock { synchronized getlock() { //####还没写完 } } 五个等级 参见effective java item 52 : document thread safety immutable 不可变对象 thread-safe 线程安全的,可以放心使用,如java.util.timer conditionally thread-safe 条件线程安全的,如vector和hashtable,一般是安全的,除非存在几个方法调用之间的顺序不能被打断,这时可以用额外的锁来完成 thread-compatible 可以使用synchronized (objectreference)来协助完成对线程的调用 thread-hostile 不安全的 wait & notifyall 在循环中使用wait 使用notifyall而不是notify pipe java中也有pipe的,四个类:pipedinputstream, pipedinputreader, pipedoutputstream, pipedoutputwriter 下面是一段生产者消费者的代码(摘自core javaii): /* set up pipes */ pipedoutputstream pout1 = new pipedoutputstream(); pipedinputstream pin1 = new pipedinputstream(pout1); pipedoutputstream pout2 = new pipedoutputstream(); pipedinputstream pin2 = new pipedinputstream(pout2); /* construct threads */ producer prod = new producer(pout1); filter filt = new filter(pin1, pout2); consumer cons = new consumer(pin2); /* start threads */ prod.start(); filt.start(); cons.start();
|
|