2008年12月1日星期一

java的线程安全

四种方式    sychronized关键字

  1. sychronized method(){}
  2. sychronized (objectReference) {/*block*/}
  3. static synchronized method(){}
  4. 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

  1. immutable   不可变对象
  2. thread-safe 线程安全的,可以放心使用,如java.util.Timer
  3. conditionally thread-safe 条件线程安全的,如Vector和Hashtable,一般是安全的,除非存在几个方法调用之间的顺序不能被打断,这时可以用额外的锁来完成
  4. thread-compatible 可以使用synchronized (objectReference)来协助完成对线程的调用
  5. 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();

注意

long 和double是简单类型中两个特殊的咚咚:java读他们要读两次,所以需要同步
 


 
 



[广告] 金秋最关注楼盘-房不胜房

3 条评论:

Unknown 说...

Java中如何使用synchronized关键字

由于同步最经常应用于this对象,在Java语言中提供了一个方便的语法,即同步化方法。例如,如下形式的方法:
void mehtod()

{

synchronized(this)

{

//临界段代码

}

}

它等价于下面的同步化方法:

synchronized void mehtod()

{

//临界段代码

}

也就是说,在方法前面加上synchronized修饰符即可以将一个方法声明为同步化方法。同步化方法在执行之前获得一个锁。

如果这是一个类方法,那么获得的锁是和声明方法的类相关的Class类对象的锁。如果这是一个实例方法,那么此锁是this对象的锁。

注意:在同步化方法中,整个方法被当作一个临界段,因此这种方法可能保护一个比实际需要的区域更大的区域,从而降低执行效率。

Unknown 说...

synchronized同步
主要用在多个线程共享数据
也就是说当某个线程被定义为synchronized以后当他在使用数据的时候
其他线程不能操作那些数据了

Unknown 说...

你用時要看看是否只允許一個線程去訪問哪一個物件
如是就要用這個字了
由於比兩個線程或以上問時訪問一個變量,哪個變量會變得不可估計的結果
你試想下
i=0
一個thread
i++
另一個又同時執行
i++
結果會如何
可能會
i=1 or i=2
這樣的程序可以嗎
這個字就是這樣用的