java线程共享受限资源 解决资源竞争 详细介绍请参阅：thinking in java4 21.3
thinking in java 4免费下载:http://download.csdn.net/detail/liangrui1988/7580155
package org.rui.thread.res;/** * 不正确的访问 资源 * @author lenovo * */public abstract class IntGenerator {private volatile boolean canceled=false;//取消的public abstract int next();// 允许这种被取消public void cancel(){canceled =true;}public boolean isCanceled(){return canceled;}}
package org.rui.thread.res;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/** * 任何IntGenerator都可以用下面的EvenCherker类来测试 * @author lenovo * */public class EvenChecker implements Runnable {private IntGenerator generator;private final int id;public EvenChecker(IntGenerator g,int ident){this.generator=g;this.id=ident;}@Overridepublic void run() {while(!generator.isCanceled()){int val=generator.next();if(val%2!=0){System.out.println(val+" not even!");generator.cancel();//cancels all evencheckers}}}///test any type of intgeneratorpublic static void test(IntGenerator gp,int count){System.out.println("press control-c to exit");ExecutorService ex=Executors.newCachedThreadPool();for(int i=0;i<count;i++){ ex.execute(new EvenChecker(gp,i));}ex.shutdown();/*for(int i=0;i<count;i++){Thread t=new Thread(new EvenChecker(gp,i));t.start();}*/}///public static void test(IntGenerator gp){test(gp,10);}}
package org.rui.thread.res;/** * 这个程序最终会失败，因为evenChecker任务在evenGenerator处于 不恰当的 状态时 * 仍能够访问其中信息 * 如果你希望更快地发现失败，可以尝试着将yield() 的调用放置到第一个和第二个递增操作之间。 * 这只是并发程序的部分部题 * @author lenovo * */public class EvenGenerator extends IntGenerator {private int currentEvenValue=0;@Overridepublic int next() {++currentEvenValue;//危险项目》的出版物! danger point here++currentEvenValue;return currentEvenValue;}public static void main(String[] args) {EvenChecker.test(new EvenGenerator());}}/** * output: press control-c to exit13103419 not even! */
package org.rui.thread.res;/** * 同步控制 EvenGenerator * @author lenovo * */public class SynchronizedEvenGenerator extends IntGenerator {private int currentEvenValue=0;@Overridepublic synchronized int next() {++currentEvenValue;Thread.yield();//导致失败的更快 暂停当前正在执行的线程对象，并执行其他线程。++currentEvenValue;return currentEvenValue;}public static void main(String[] args) {EvenChecker.test(new SynchronizedEvenGenerator());}}/** output: press control-c to exit */
package org.rui.thread.res;import java.util.concurrent.locks.Lock;import java.util.concurrent.locks.ReentrantLock;/** * 使用显示的Lock对象 * @author lenovo * */public class MutexEvenGenerator extends IntGenerator {private int currentEvenValue=0;Lock lock=new ReentrantLock();@Overridepublic int next() {lock.lock();try {++currentEvenValue;Thread.yield();//导致失败的更快 暂停当前正在执行的线程对象，并执行其他线程。++currentEvenValue;return currentEvenValue;} finally{lock.unlock();}}//////////////////////////////public static void main(String[] args) {EvenChecker.test(new MutexEvenGenerator());}}/**output:press control-c to exit*/
package org.rui.thread.res;import java.util.concurrent.TimeUnit;import java.util.concurrent.locks.ReentrantLock;/** * synchronized关键字不能尝试着获取锁且最终获取锁会失败 * 或都尝试获取一段时间 ，然后放弃它，要实现这些，你必须使用concurrent类库： * * * ReentrantLock允许你尝试着获取但最终末获取锁，这样如果其他人已经获取了这个锁， * 那么你就可以决定离开去执行其他一些事件，而不是等待直至这个锁被释放，就像在untimed()方法中所看到的。 * 在timed中 做出尝试去获取锁，该尝试可以在2秒之后失败 * @author lenovo * */public class AttemptLocking {//可重入的互斥锁private ReentrantLock lock=new ReentrantLock();public void untimed()//不计时的{// 仅在调用时锁未被另一个线程保持的情况下，才获取该锁。boolean captured=lock.tryLock();try {System.out.println("tryLock(): "+captured);} finally{if(captured)lock.unlock();}}/////////////public void timed()//计时{boolean captured=false;try {//如果锁在给定等待时间内没有被另一个线程保持，且当前线程未被中断，则获取该锁。captured=lock.tryLock(2,TimeUnit.SECONDS);} catch(InterruptedException e){throw new RuntimeException(e);}try {System.out.println("tryLock(2,TimeUnit.SECONDS) : "+captured);} finally{if(captured)lock.unlock();}}///////////////mainpublic static void main(String[] args) throws InterruptedException {final AttemptLocking al=new AttemptLocking();al.untimed();//true -- lock is available 锁可用al.timed();//true -- lock is available//现在创建一个单独的任务获取锁 使下面的线程调用产生竞争new Thread(){{setDaemon(true);}@Overridepublic void run() {al.lock.lock();System.out.println("acquired");}}.start();Thread.sleep(1000);// 暂停当前正在执行的线程对象，并执行其他线程。//Thread.yield();//give the 2nd task a chance 给第二个任务一个机会al.untimed();//false--lock grabbed by task 锁了的任务al.timed();//false--lock grabbed by task}}/** * output:tryLock(): truetryLock(2,TimeUnit.SECONDS) : trueacquiredtryLock(): falsetryLock(2,TimeUnit.SECONDS) : false */
微笑的去寻找一个不可能出现的你。
