java高级工程师多线程并发

• 线程池（java5中）

ExecutorService threadPool =Executors.newFixedThreadPool(3);//创建固定大小的线程池

ExecutorService threadPool=Executors.newCachedThreadPool();//创建缓存线程池，动态变化线程数量，一段时间之后销毁未使用的线程

ExecutorService threadPool=Executors.newSingleThreadExecutor();//创建单一线程，当线程死掉之后立马启动替补线程

• lock  condition 实现线程同步通信

lock类似于synchronized,但是比synchronize更加面向对象化

使用： Lock lock=new  Reentranlock();

lock.lock();      lock.unlock();

• 读写锁的应用ReadWriteLock    rwl=new   ReentrantReadWriteLock();

缓存系统的实现-------

public  class CacheDemo{

            private Map<String,Object>  cache=new HashMap<String,Object>();

           private ReadWriteLock rwl=new ReentrantReadWriteLock();

           public  Object  getData(String  key){

            rwl.readLock().lock();  //读之间可以不挂锁，但是怕是内存中没值，就得读数据库然后往缓存中写数据，所以挂上

           Object value= null;

try{

          value=cache.get(key);

         if(value==null){

                      rwl.readLock().unlock();//如果没有数据就得进行写操作，就得将读解锁，开启写锁

                      rwl.writeLock().lock();

          try{

if(value==null){//多个线程都走到rml.writeLock().lock()时，一个线程写入成功之后，则此时后面线程再到这一步时的判断缓存中是否有数据

                  value="aaa";

}              

}

           finally{

                  rwl.writeLock().lock();

              }

                 rwl.readLock().lock();

            }

          }

         finally{

                       rwl.readLock().unlock();

                  }

              return value;

            }

}