Java多线程及同步实现原理 - 编程入门网
Seq() {} synchronized public static Seq getInstance() { //(1) if(seq==null) seq = new Seq(); return seq; } public synchronized int get() { number++; return number; }}
例6把getInstance()函数声明为synchronized,那样就保证通过getInstance()得到的是同一个seq对象。 2.2 non-static的synchronized数据只能在同一个对象的纯种实现同步访问,不同对象的线程仍可同时访问。 例7: class TestSynchronized implements Runnable{ public synchronized void run() { //(1) for(int i=0; i<10; i++) { System.out.println(Thread.currentThread().getName() + " : " + i); /*(2)*/ try { Thread.sleep(100); } catch(InterruptedException e) { System.out.println("Interrupted"); } } }}public class TestThread{ public static void main(String[] args) { TestSynchronized r1 = new TestSynchronized(); TestSynchronized r2 = new TestSynchronized(); Thread t1 = new Thread(r1, "t1"); Thread t2 = new Thread(r2, "t2"); //(3) // Thread t2 = new Thread(r1, "t2"); (4) t1.start(); t2.start(); }}
运行结果为: t1 : 0 t2 : 0 t1 : 1 t2 : 1 t1 : 2 t2 : 2 t1 : 3 t2 : 3 t1 : 4 t2 : 4 t1 : 5 t2 : 5 t1 : 6 t2 : 6 t1 : 7 t2 : 7 t1 : 8 t2 : 8 t1 : 9 t2 : 9 Java多线程及同步实现原理(7)时间:2007-11-05虽然我们在代码(1)中把run()函数声明为synchronized,但由于t1、t2是两个对象(r1、r2)的线程,而run()函数是non-static的synchronized数据,所以仍可被同时访问(代码(2)中的sleep()函数由于在暂停时不会释放“标志锁”,因为线程中的循环很难被中断去执行另一个线程,所以代码(2)只是为了显示结果)。 如果把例7中的代码(3)注释掉,并去年代码(4)的注释,运行结果将为: t1 : 0 t1 : 1 t1 : 2 t1 : 3 t1 : 4 t1 : 5 t1 : 6 t1 : 7 t1 : 8 t1 : 9 t2 : 0 t2 : 1 t2 : 2 t2 : 3 t2 : 4 t2 : 5 t2 : 6 t2 : 7 t2 : 8 t2 : 9 修改后的t1、t2是同一个对象(r1)的线程,所以只有当一个线程(t1或t2中的一个)执行run()函数,另一个线程才能执行。 2.3 对象的“锁标志”和class的“锁标志”是相互独立的。 例8: class TestSynchronized extends Thread{ public TestSynchronized(String name) { super(name); } public synchronized static void prt() { for(int i=10; i<20; i++) { System.out.println(Thread.currentThread().getName() + " : " + i); try { Thread.sleep(100); } catch(InterruptedException e) { System.out.println("Interrupted"); } } } public synchronized void run() { for(int i=0; i<10; i++) { System.out.println(Thread.currentThread().getName() + " : " + i); try { Thread.sleep(100); } catch(InterruptedException e) { System.out.println("Interrupted"); } } }}public class TestThread{ public static void main(String[] args) { TestSynchronized t1 = new TestSynchronized("t1"); TestSynchronized t2 = new TestS |
凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务,公司网站:http://www.lingzhong.cn 为了给广大客户了解更多的技术信息,本技术文章收集来源于网络,凌众科技尊重文章作者的版权,如果有涉及你的版权有必要删除你的文章,请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢! |