9992019.com(澳门银河官网) 1

许多朋友没有从硬盘安装Ubuntu
7.10的,而是从ubuntu 7.04直接升级到ubuntu 7.10的,但是需要注意

java并发之Lock

从Java
5之后,在java.util.concurrent.locks包下提供了另外一种方式来实现同步访问,那就是Lock。

 

 1.Lock

  首先要说明的就是Lock,通过查看Lock的源码可知,Lock是一个接口:

1 2 3 4 5 6 7 8 publicinterfaceLock { voidlock(); voidlockInterruptibly()throwsInterruptedException; booleantryLock(); booleantryLock(longtime, TimeUnit unit)throwsInterruptedException; voidunlock(); Condition newCondition(); }

  下面来逐个讲述Lock接口中每个方法的使用,lock()、tryLock()、tryLock(long
time, TimeUnit
unit)和lockInterruptibly()是用来获取锁的。unLock()方法是用来释放锁的。newCondition()这个方法暂且不在此讲述,会在后面的线程协作一文中讲述。

  在Lock中声明了四个方法来获取锁,那么这四个方法有何区别呢?

  首先lock()方法是平常使用得最多的一个方法,就是用来获取锁。如果锁已被其他线程获取,则进行等待。

  由于在前面讲到如果采用Lock,必须主动去释放锁,并且在发生异常时,不会自动释放锁。因此一般来说,使用Lock必须在try{}catch{}块中进行,并且将释放锁的操作放在finally块中进行,以保证锁一定被被释放,防止死锁的发生。通常使用Lock来进行同步的话,是以下面这种形式去使用的:

1 2 3 4 5 6 7 8 9 Lock lock = ...; lock.lock(); try{ //处理任务 }catch(Exception ex){ }finally{ lock.unlock();//释放锁 }

  tryLock()方法是有返回值的,它表示用来尝试获取锁,如果获取成功,则返回true,如果获取失败(即锁已被其他线程获取),则返回false,也就说这个方法无论如何都会立即返回。在拿不到锁时不会一直在那等待。

  tryLock(long time, TimeUnit
unit)方法和tryLock()方法是类似的,只不过区别在于这个方法在拿不到锁时会等待一定的时间,在时间期限之内如果还拿不到锁,就返回false。如果如果一开始拿到锁或者在等待期间内拿到了锁,则返回true。

  所以,一般情况下通过tryLock来获取锁时是这样使用的:

1 2 3 4 5 6 7 8 9 10 Lock lock = ...; if(lock.tryLock()) { try{ //处理任务 }catch(Exception ex){ }finally{ lock.unlock();//释放锁 } }else{ //如果不能获取锁,则直接做其他事情 }

  lockInterruptibly()方法比较特殊,当通过这个方法去获取锁时,如果线程正在等待获取锁,则这个线程能够响应中断,即中断线程的等待状态。也就使说,当两个线程同时通过lock.lockInterruptibly()想获取某个锁时,假若此时线程A获取到了锁,而线程B只有在等待,那么对线程B调用threadB.interrupt()方法能够中断线程B的等待过程。

  由于lockInterruptibly()的声明中抛出了异常,所以lock.lockInterruptibly()必须放在try块中或者在调用lockInterruptibly()的方法外声明抛出InterruptedException。

  因此lockInterruptibly()一般的使用形式如下:

1 2 3 4 5 6 7 8 9 publicvoidmethod()throwsInterruptedException { lock.lockInterruptibly(); try{ //..... } finally{ lock.unlock(); } }

  注意,当一个线程获取了锁之后,是不会被interrupt()方法中断的。因为本身在前面的文章中讲过单独调用interrupt()方法不能中断正在运行过程中的线程,只能中断阻塞过程中的线程。

  因此当通过lockInterruptibly()方法获取某个锁时,如果不能获取到,只有进行等待的情况下,是可以响应中断的。

  而用synchronized修饰的话,当一个线程处于等待某个锁的状态,是无法被中断的,只有一直等待下去。

  2.ReentrantLock

  ReentrantLock,意思是“可重入锁”,关于可重入锁的概念在下一节讲述。ReentrantLock是唯一实现了Lock接口的类,并且ReentrantLock提供了更多的方法。下面通过一些实例看具体看一下如何使用ReentrantLock。

  例子1,lock()的正确使用方法

1 2 3 4 5 6 7 8 9 10  publicclassTest { privateArrayList arrayList =newArrayList(); publicstaticvoidmain(String[] args) { finalTest test =newTest(); newThread(){ publicvoidrun() { test.insert(Thread.currentThread()); }; }.start(); newThread(){ publicvoidrun() { test.insert(Thread.currentThread()); }; }.start(); } publicvoidinsert(Thread thread) { Lock lock =newReentrantLock();//注意这个地方 lock.lock(); try{ System.out.println(thread.getName()+"得到了锁"); for(inti=0;i<5;i++) { arrayList.add(i); } }catch(Exception e) { // TODO: handle exception }finally{ System.out.println(thread.getName()+"释放了锁"); lock.unlock(); } } }

  各位朋友先想一下这段代码的输出结果是什么?

9992019.com(澳门银河官网) 2

Thread-0得到了锁
Thread-1得到了锁
Thread-0释放了锁
Thread-1释放了锁

  也许有朋友会问,怎么会输出这个结果?第二个线程怎么会在第一个线程释放锁之前得到了锁?原因在于,在insert方法中的lock变量是局部变量,每个线程执行该方法时都会保存一个副本,那么理所当然每个线程执行到lock.lock()处获取的是不同的锁,所以就不会发生冲突。

  知道了原因改起来就比较容易了,只需要将lock声明为类的属性即可。

1 2 3 4 5 6 7 8 9 10  publicclassTest { privateArrayList arrayList =newArrayList(); privateLock lock =newReentrantLock();//注意这个地方 publicstaticvoidmain(String[] args) { finalTest test =newTest(); newThread(){ publicvoidrun() { test.insert(Thread.currentThread()); }; }.start(); newThread(){ publicvoidrun() { test.insert(Thread.currentThread()); }; }.start(); } publicvoidinsert(Thread thread) { lock.lock(); try{ System.out.println(thread.getName()+"得到了锁"); for(inti=0;i<5;i++) { arrayList.add(i); } }catch(Exception e) { // TODO: handle exception }finally{ System.out.println(thread.getName()+"释放了锁"); lock.unlock(); } } }

  这样就是正确地使用Lock的方法了。

  例子2,tryLock()的使用方法

1 2 3 4 5 6 7 8 9 10  publicclassTest { privateArrayList arrayList =newArrayList(); privateLock lock =newReentrantLock();//注意这个地方 publicstaticvoidmain(String[] args) { finalTest test =newTest(); newThread(){ publicvoidrun() { test.insert(Thread.currentThread()); }; }.start(); newThread(){ publicvoidrun() { test.insert(Thread.currentThread()); }; }.start(); } publicvoidinsert(Thread thread) { if(lock.tryLock()) { try{ System.out.println(thread.getName()+"得到了锁"); for(inti=0;i<5;i++) { arrayList.add(i); } }catch(Exception e) { // TODO: handle exception }finally{ System.out.println(thread.getName()+"释放了锁"); lock.unlock(); } }else{ System.out.println(thread.getName()+"获取锁失败"); } } }

  输出结果:

9992019.com(澳门银河官网) 3

Thread-0得到了锁
Thread-1获取锁失败
Thread-0释放了锁

  例子3,lockInterruptibly()响应中断的使用方法:

1 2 3 4 5 6 7 8 9 10 publicclassTest { privateLock lock =newReentrantLock(); publicstaticvoidmain(String[] args) { Test test =newTest(); MyThread thread1 =newMyThread(test); MyThread thread2 =newMyThread(test); thread1.start(); thread2.start(); try{ Thread.sleep(2000); }catch(InterruptedException e) { e.printStackTrace(); } thread2.interrupt(); } publicvoidinsert(Thread thread)throwsInterruptedException{ lock.lockInterruptibly();//注意,如果需要正确中断等待锁的线程,必须将获取锁放在外面,然后将InterruptedException抛出 try{ System.out.println(thread.getName()+"得到了锁"); longstartTime = System.currentTimeMillis(); for( ; 😉 { if(System.currentTimeMillis() - startTime >= Integer.MAX_VALUE) break; //插入数据 } } finally{ System.out.println(Thread.currentThread().getName()+"执行finally"); lock.unlock(); System.out.println(thread.getName()+"释放了锁"); } } } classMyThreadextendsThread { privateTest test =null; publicMyThread(Test test) { this.test = test; } @Override publicvoidrun() { try{ test.insert(Thread.currentThread()); }catch(InterruptedException e) { System.out.println(Thread.currentThread().getName()+"被中断"); } } }

  运行之后,发现thread2能够被正确中断。

  3.ReadWriteLock

  ReadWriteLock也是一个接口,在它里面只定义了两个方法:

1 2 3 4 5 6 7 8 9 10  publicinterfaceReadWriteLock { /** * Returns the lock used for reading. * * @return the lock used for reading. */ Lock readLock(); /** * Returns the lock used for writing. * * @return the lock used for writing. */ Lock writeLock(); }

  一个用来获取读锁,一个用来获取写锁。也就是说将文件的读写操作分开,分成2个锁来分配给线程,从而使得多个线程可以同时进行读操作。下面的ReentrantReadWriteLock实现了ReadWriteLock接口。

  4.ReentrantReadWriteLock

  ReentrantReadWriteLock里面提供了很多丰富的方法,不过最主要的有两个方法:readLock()和writeLock()用来获取读锁和写锁。

  下面通过几个例子来看一下ReentrantReadWriteLock具体用法。

  假如有多个线程要同时进行读操作的话,先看一下synchronized达到的效果:

1 2 3 4 5 6 7 8 9 10  publicclassTest { privateReentrantReadWriteLock rwl =newReentrantReadWriteLock(); publicstaticvoidmain(String[] args) { finalTest test =newTest(); newThread(){ publicvoidrun() { test.get(Thread.currentThread()); }; }.start(); newThread(){ publicvoidrun() { test.get(Thread.currentThread()); }; }.start(); } publicsynchronizedvoidget(Thread thread) { longstart = System.currentTimeMillis(); while(System.currentTimeMillis() - start <=1) { System.out.println(thread.getName()+"正在进行读操作"); } System.out.println(thread.getName()+"读操作完毕"); } }

  这段程序的输出结果会是,直到thread1执行完读操作之后,才会打印thread2执行读操作的信息。

9992019.com(澳门银河官网) 4Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0读操作完毕
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1读操作完毕

  而改成用读写锁的话:

1 2 3 4 5 6 7 8 9 10 publicclassTest { privateReentrantReadWriteLock rwl =newReentrantReadWriteLock(); publicstaticvoidmain(String[] args) { finalTest test =newTest(); newThread(){ publicvoidrun() { test.get(Thread.currentThread()); }; }.start(); newThread(){ publicvoidrun() { test.get(Thread.currentThread()); }; }.start(); } publicvoidget(Thread thread) { rwl.readLock().lock(); try{ longstart = System.currentTimeMillis(); while(System.currentTimeMillis() - start <=1) { System.out.println(thread.getName()+"正在进行读操作"); } System.out.println(thread.getName()+"读操作完毕"); }finally{ rwl.readLock().unlock(); } } }

  此时打印的结果为:

9992019.com(澳门银河官网) 5

Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0正在进行读操作
Thread-1正在进行读操作
Thread-0读操作完毕
Thread-1读操作完毕

  说明thread1和thread2在同时进行读操作。

  这样就大大提升了读操作的效率。

  不过要注意的是,如果有一个线程已经占用了读锁,则此时其他线程如果要申请写锁,则申请写锁的线程会一直等待释放读锁。

  如果有一个线程已经占用了写锁,则此时其他线程如果申请写锁或者读锁,则申请的线程会一直等待释放写锁。

  关于ReentrantReadWriteLock类中的其他方法感兴趣的朋友可以自行查阅API文档

 

从Java
5之后,在java.util.concurrent.locks包下提供了另外一种方式来实现同步访问,那就是Lock。
1.Lock 首先要说明的就是Lock,通过…

一辆右转的半挂撞了一辆兰博基尼,目前双方正在调解……

请使用 系统 -> 系统管理 -> 更新管理器 来升级

相关文章

相关搜索:
java并发之Lock

今天看啥

搜索技术库

返回首页

相关频道:
Java编程  C#教程  C语言  C++教程  VC教程  Delphi教程  VB教程  工具软件  

9992019.com(澳门银河官网) 6

命令行使用:
代码:
sudo apt-get install update-manager-core
sudo do-release-upgrade

帮客评论

兰博司机有点背景 准备叫人了……过了10分钟就来了十来辆车 聚集了100人上下

来升级。
不要使用 sudo apt-get dist-upgrade 升级。
此命令无法保证正确的升级。
已知问题:会出现
代码:
device-mapper: table: 254:3: linear: dm-linear: Device lookup failed
device-mapper: ioctl: error adding target to table

9992019.com(澳门银河官网) 7

的异常。处理办法,删除 evms 及相关包。

半挂车不甘示弱,呼朋唤友,事来了我不怕

需要删除的包:
引用:
正在删除 cdrecord …
正在删除 desktop-effects …
正在删除 esound …
正在删除 evms-ncurses …
正在删除 evms …
update-initramfs: deferring update (trigger activated)
正在删除 feisty-session-splashes …
正在删除 feisty-wallpapers …
正在删除 gaim …
正在删除 gaim-data …
正在删除 gs-common …
正在删除 gs-esp-x …
正在删除 libcurl3 …
正在删除 libevms-2.5 …
正在删除 libflac++5c2 …
正在删除 libflac7 …
正在删除 libgcj7-0 …
正在删除 libgda2-3 …
正在删除 libgda2-common …
正在删除 libgdiplus …
正在删除 libgnomecupsui1.0-1c2a …
正在删除 libgpod1 …
正在删除 libgs-esp8 …
正在删除 libgstreamer-plugins-pulse0.10-0 …
正在删除 libjack0.100.0-0 …
正在删除 libjasper-1.701-1 …
正在删除 libmdbtools …
正在删除 libneon25 …
正在删除 libnspr4 …
正在删除 libpoppler1-glib …
正在删除 libpoppler1 …
正在删除 libquicktime0 …
正在删除 libservlet2.3-java …
正在删除 libslab0 …
正在删除 libsnmp9 …
正在删除 libstlport5.1 …
正在删除 libswfdec0.3 …
正在删除 libtotem-plparser1 …
正在删除 libwvstreams4.2-extras …
正在删除 libwvstreams4.2-base …
正在删除 linux-headers-2.6.20-15-generic …
正在删除 linux-headers-2.6.20-16-generic …
正在删除 linux-headers-2.6.20-16 …
正在删除 nfs-kernel-server …
* Stopping NFS kernel daemon [ OK ]
* Unexporting directories for NFS kernel daemon… [ OK ]
正在删除 vmware-server-kernel-modules-2.6.20-15 …
Processing triggers for initramfs-tools …
update-initramfs: Generating /boot/initrd.img-2.6.22-14-generic
Processing triggers for libc6 …
ldconfig deferred processing now taking place

9992019.com(澳门银河官网) 8

无法连上Internet使用 alternate CD/DVD 来升级
挂载iso后,执行:
gksu “sh /cdrom/cdromupgrade” 或 kdesu “sh /cdrom/cdromupgrade”

相关文章