《Java并发编程实践分享.ppt》由会员分享，可在线阅读，更多相关《Java并发编程实践分享.ppt（30页珍藏版）》请在taowenge.com淘文阁网|工程机械CAD图纸|机械工程制图|CAD装配图下载|SolidWorks_CaTia_CAD_UG_PROE_设计图分享下载上搜索。
1、Java并发编程实践分享 WA定时器编程经验分享cesc.wangl以下方法哪个是线程安全第一个方法：第一个方法：public void add(int i)i+;第二个方法：第二个方法：public Object getLast(List list)int lastIndex=list.size()-1;return list.get(lastIndex);第三个方法：第三个方法：public Object getLast(Vector v)int lastIndex=v.size()-1;return v.get(lastIndex);第一个方法：第一个方法：private static
2、void testList()Listtests=new ArrayList();tests.add(a);tests.add(b);tests.add(“temp);tests.add(c);for(String test:tests)if(test.equals(b)tests.remove(“temp);System.out.println(test);第二个方法：第二个方法：private static void testVector()Vectortests=new Vector();tests.add(a);tests.add(b);tests.add(“temp);tests.a
3、dd(c);for(String test:tests)if(test.equals(b)tests.remove(“temp);System.out.println(test);执行结果什么？1.JUC简介简介2.线程池线程池3.Atomic4.Lock5.并发编程注意事项并发编程注意事项JDK1.5新增的类库提供并发编程中很常用的实用工具类线程池选哪个？多少线程合适？多大的队列合适？第一个问题ThreadPoolExecutorExecutorsBlockingQueuecorePoolSize/核心池的大小maxPoolSize/最大池的大小keepAliveTime/超时时间workQ
4、ueue/等待队列handler/饱和策略corePoolSize=CPU个数+1（计算密集型的操作）（JavaConcurrencyInPractice）AbortPolicy抛异常RejectedExecutionExceptionCallerRunsPolicy调度者执行DiscardOldestPolicy放弃最旧的未处理请求，执行新传入的任务DiscardPolicy不做任何操作，放弃新任务BlockingQueueput put、taketake生产者与消费者（工作队列与线程池）生产者与消费者（工作队列与线程池）新的请求超过线程池的处理能力，将请求放在队列中，而不是竞争新的请求超过
5、线程池的处理能力，将请求放在队列中，而不是竞争CPUCPU资资源的线程队列，避免耗尽资源的情况出现源的线程队列，避免耗尽资源的情况出现ArrayBlockingQueueArrayBlockingQueue、LinkedBlockingDeque LinkedBlockingDeque、SynchronousQueue SynchronousQueue注：如果任务之间有依赖，有限队列可能引起线程饥饿和死锁问题。注：如果任务之间有依赖，有限队列可能引起线程饥饿和死锁问题。各种线程池线程池线程池SingleThreadPoolCachedThreadPoolFixedThreadPoolcoolP
6、oolSize10-maxPoolSize1Integer.MAX_VALUE-QueueLinkedBlockingQueueSynchronousQueueLinkedBlockingQueuehandlerAbortPolicyAbortPolicyAbortPolicykeepAliveTime060min0线程池两种常用策略：1、小池+大队列控制对CPU以及内存的使用，减少线程上下文切换2、大池+无队列大吞吐量、高效的移交任务WA使用Spring封装的线程池ThreadPoolTaskExecutorcoolPoolSize：5maxPoolSize：5Queue：LinkedBlo
7、ckingQueue10000Handler：AbortPolicy批量执行下，需要记录每个线程是否执行完毕，来控制主线程是否继续下一个批量的执行第二个问题计数器？并发？synchronized？AtomicInteger“可以用原子方式更新的 int值。”CAS（CompareAndSet）volatile（线程可见性）非阻塞算法（乐观锁）privatevolatileintvalue;publicfinalintget()returnvalue;publicfinalintincrementAndGet()for(;)intcurrent=get();intnext=current+1;i
8、f(compareAndSet(current,next)returnnext;thread1thread2thread3thread4HeapPermgenHeapcodeStackStackStackStackobjobjobjNativeheapOStaskschedulerCPUcore1core2CPUcore1core2CPUcore1core2CPUcore1core2synchronized与非阻塞算法1、使用硬件的原生指令，降低了争用的成本2、在轻度与中度争用情况下，更有性能优势3、重度争用时阻塞算法性能更好，但是重度的争用往往说明算法需要调整CountDownLatch（闭
9、锁）确保特定的活动直到其他活动完成后才发生CountDownLatch(int)await()countDown()publicstaticvoidfinishOneTask()latch.countDown();publicstaticvoidisFinish()throwsInterruptedExceptionlatch.await();publicstaticvoidinit(intinitNum)latch=newCountDownLatch(initNum);第三个问题如何精确控制发送速率？synchronizedLockReentrantLocksynchronized与Lock
10、比较1、Lock与synchronized功效是一样的2、Lock提供更好的灵活度和可伸缩性3、在Java1.5中Lock的性能明显强于synchronized，1.6中差距不明显4、使用Lock一定要记住在finally释放锁ReentrantLocklock=LimitSendNumUtil.getLock();trylock.lock();if(!LimitSendNumUtil.isSend()/线程sleepThread.sleep(sleepTime);AliMailClient.synSend(mail);finallyLimitSendNumUtil.send();if(loc
11、k.isLocked()lock.unlock();并发容器ConcurrentHashMapl线程安全l支持并发、无阻塞l锁分离lvolatile、读不加锁l较HashMap，高并发情景下（50-100线程并发）添加和删除性能提高一倍，查找性能提高10倍并发编程注意事项并发编程注意事项1、线程设置名称2、Atomic+Atomic!=Atomic3、响应中断InterruptedException4、不要误杀线程(运行定时器时要使全部线程都结束才可以退出)5、编写多线程程序，要加相关注释（方法是否线程安全、适用在那种场景使用此类或方法）6、使用Lock要在finally中释放Lock7、使用
12、volatile只能增加可见性，没有同步语义8、调试Java多线程代码的指令jpsjstackpidvisualvm（图形界面）误吃掉中断的后果InterruptedException1、中断是一种协作机制，其他线程不能够迫使其他线程停止。2、中断可以认为是“提醒”。3、响应中断的阻塞方法可以更容易的取消耗时的操作。响应线程中断的两种方式：1、传递InterruptedException2、恢复中断Thread.currentThread().interrupt()Thread7371:(state=BLOCKED)-java.lang.Object.wait(long)bci=0(Compi
13、ledframe;informationmaybeimprecise)-java.lang.Object.wait()bci=2,line=474(Compiledframe)Thread7357:(state=IN_NATIVE)-org.eclipse.swt.internal.gtk.OS.Call(int,int,int,int)bci=0(Compiledframe;informationmaybeimprecise)-org.eclipse.swt.widgets.Display.sleep()bci=265,line=3893(Compiledframe)-org.eclipse.ui.application.WorkbenchAdvisor.eventLoopIdle(org.eclipse.swt.widgets.Display)bci=1,line=364(Compiledframe)-org.eclipse.ui.internal.Workbench.runUI()bci=393,line=2369(Interpretedframe)Thanks