读书人

Java线程(2)

发布时间: 2012-12-25 16:18:28 作者: rapoo

Java线程(二)

浅谈synchronized应用于类方法和类字面量之上

???? ? 当调用一个synchronized static函数时,获得的lock将与定义该方法的class的Class对象相关联,而不是与调用方法的那个实例对象相关联。当你对一个class literal调用其synchronized代码块时,获得的也是同样那个lock,与特定Class对象相关联的lock,类的所有实例共享 。

?????? 说明:上述代码由于是synchronized instance方法,故使用的是instance对象锁,不同的对象具有不同的对象锁。线程tone和线程ttwo使用的是目标对象run和run2的 run()方法,在run()方法中调用了printVal()方法,由于线程访问的是不同对象(run和run2)的synchronized方法,故两个线程可以并行执行,无需等待对象锁。

????? 如果我们将上面的代码略加修改,即:

?????? 说明:经修改后实际和synchronized static void 方法的效果是一样的。

?????? 举例3.

?????? 说明:在输出时线程main和线程thread交替输出。线程thread仅仅调用synchronized instance(此处的对象为run)方法printMOne(),在无限循环中打印字符串"printMOne"。主线程main则调用了(此处也是对象run)synchronized static方法printMTwo(),它也进入自身的无限循环中,打印字符串"printMTwo"。

?????? 你或许会以为:由于这两个线程(main线程和thread线程)的执行过程中访问的是同一个对象(run)的两个不同synchronized方法,故无法在上述两方法之间交替。这段代码的输出不是字符串"printMOne"就是字符串"printMTwo"一一取决于哪个线程率先进入其synchronized方法并获得lock。

?????? 然而,当上述代码执行起来,两个字符串都打印在屏幕上,也就是说,两个方法并发执行。

?????? 解析:尽管上述两个方法都声明为synchronized,但它们并非线程安全(thread safe)的,其原因在于一个是synchronized static方法,另一个是synchronized instance方法,因此它们争取的是不同的locks。instance方法printMOne()取得的是TestStaticInstanceRunnable object lock,
static方法printMTwo()取得的是TestStaticInstanceRunnable的Class object lock,是不同的两个locks,彼此互不
影响。

?????? 如果希望上述代码在多线程情况下只有一个线程可以得到锁的话,必须为synchronized锁定的是相同的(相同的instance object或Class object),将方法printOne修改成如下形式,则两个方法是用相同的Class object lock。

?????? 如果需要同步控制这段代码,又该怎么办呢?两种选择可以解决这个问题:

?????? 1.同步控制(synchronize)公用资源。??? ???
?? ? ? 2.同步控制(synchronize)—个特殊的instance变量。

?????? 对于1涉及在函数中添加synchronized语句,以便同步控制共享资源。假设两个方法要更新同一个对象,它们就对其进行同步控制。

public class TestStaticInstanceRunnable implements Runnable {private byte [] bytes = new byte[0];          //关键在于多线程中锁一定是相同的public void printMOne() {synchronized(bytes) {while (true) {/** ...... */}}}public static void printMTwo(TestStaticInstanceRunnable run) {synchronized(run.bytes) {while (true) {/** ...... */}}}public void run() {printMOne();}@SuppressWarnings("static-access")public static void main(String[] args) {TestStaticInstanceRunnable run = new TestStaticInstanceRunnable();Thread thread = new Thread(run, "thread");thread.start();run.printMTwo(run);}}

? <<To Be Continued>>

读书人网 >编程

热点推荐