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;

            }

}

原文地址:https://www.cnblogs.com/javawebsoa/p/3043277.html