皮皮网

1.学习Java，码学都要学哪些课程?习需
2.JAVA培训一般需要多久？
3.硬核干货：4W字从源码上分析JUC线程池ThreadPoolExecutor的实现原理
4.Java多线程:JUC并发工具原理

学习Java，都要学哪些课程?多久

       来看看千锋武汉Java开发基础学习路线图是怎么样的：

       1、认识java语言，码学包括jdk、习需jvm等等，多久不买是傻子指标源码知道代码从写好到实现之间的码学流程。

       2、习需学习java基本语法。多久

       3、码学学习操作系统里的习需各种基本算法，因为下一阶段的多久线程可能会用到。

       4、码学开始学习j2se，习需主要包括面向对象的多久关系、线程、集合文件等等。

       5、此阶段结束可以做一些桌面程序等等小应用。

       6、android 抽奖源码进入j2ee学习，首先学习一些基本的前端知识，html、css、javascript、jquery、ajax

       7、深入学习一些前端东西，比如easyui、bootstrap、vue等等。

       8、进入后端学习jsp、servlet。

       9、学习数据库mysql、oracle、sqlserver、DB2.

       、linux源码学习学习ssh框架，因为小部分企业目前还在使用此框架。

       、深入学习ssm框架，由于很多企业开发都使用此框架进行开发。

       、着重理解掌握spring框架，并且能够最终源码。

       、学习各种设计模式，试着自己去写一写简单的框架。

       、学习其他后台框架，比如activiti等。

       、maven、git、svn等项目管理工具的使用。

       、源码 source insight学习面向服务的体系结构soa、webservice等

       、jms、EJB的开发等。

       、了解并使用weblogic、websphere等。

       、JVM优化、java程序性能优化等。

       、学习分布式技术tomcat、Nginx、并发控制等等。

       想系统学习Java，是要付出很多的精力的。可以从讲师水平、学习的内容，环境，centos .php 源码是否面授几方面选择，适合自己的才是最好的。最好去实地看看，可以去千锋试听一下，不过再好的学校自己不努力还是不行。

JAVA培训一般需要多久？

       一般情况下，基础薄弱的同学。

       按照每天8-小时的学习进度，需要5个月左右的学习时间。

       当然，每个人的接收速度不一样，所以略微会有一些差别。

       至于哪个机构好，目前在培训市场有很多的培训班，但那个培训班更好呢？说实话谁也说不清楚，因为实在是太难辨别了。

       如果现在要找培训班学习的话自己尽量还是要去实地去详细地了解一下，毕竟现在的那多的Java培训班哪家的口碑比较好，哪家老师厉害，哪家的课程体系更适合自己呢？这些如果不去实地感受真的很难感受到。除非是自己身边的朋友有去过的才能够了解个大概。

       如果自己没有太多的时间去实地了解的话，可以先去了解一下培训机构的相关视频，可以间接的感受一下，如果这都不行的话那么实际的更加不好了。选择培训前一定要慎重，如果时间充足的话尽量选择脱产全程面授班的课程学习。

       如果您要选择机构，不妨了解下我们尚学堂，专注Java培训年，性价比高，真正的做教育，老师很负责，一直秉承着让人人都能享受高品质教育的理念。

       希望能帮到您，望采纳！！

硬核干货：4W字从源码上分析JUC线程池ThreadPoolExecutor的实现原理

       深入剖析JUC线程池ThreadPoolExecutor的执行核心

       早有计划详尽解读ThreadPoolExecutor的源码，因事务繁忙未能及时整理。在之前的文章中，我们曾提及Doug Lea设计的Executor接口，其顶层方法execute()是线程池扩展的基础。本文将重点关注ThreadPoolExecutor#execute()的实现，结合简化示例，逐步解析。

       ThreadPoolExecutor的核心功能包括固定的核心线程、额外的非核心线程、任务队列和拒绝策略。它的设计巧妙地运用了JUC同步器框架AbstractQueuedSynchronizer(AQS)，以及位操作和CAS技术。以核心线程为例，设计上允许它们在任务队列满时阻塞，或者在超时后轮询，而非核心线程则在必要时创建。

       创建ThreadPoolExecutor时，我们需要指定核心线程数、最大线程数、任务队列类型等。当核心线程和任务队列满载时，会尝试添加额外线程处理新任务。线程池的状态控制至关重要，通过整型变量ctl进行管理和状态转换，如RUNNING、SHUTDOWN、STOP等，状态控制机制包括工作线程上限数量的位操作。

       接下来，我们深入剖析execute()方法。首先，方法会检查线程池状态和工作线程数量，确保在需要时添加新线程。这里涉及一个疑惑：为何需要二次检查？这主要是为了处理任务队列变化和线程池状态切换。任务提交流程中，addWorker()方法负责创建工作线程，其内部逻辑复杂，包含线程中断和适配器Worker的创建。

       Worker内部类是线程池核心，它继承自AQS，实现Runnable接口。Worker的构造和run()方法共同确保任务的执行，同时处理线程中断和生命周期的终结。getTask()方法是工作线程获取任务的关键，它会检查任务队列状态和线程池大小，确保资源的有效利用。

       线程池关闭操作通过shutdown()、shutdownNow()和awaitTermination()方法实现，它们涉及线程中断、任务队列清理和状态更新等步骤，以确保线程池的有序退出。在这些方法中，可重入锁mainLock和条件变量termination起到了关键作用，保证了线程安全。

       ThreadPoolExecutor还提供了钩子方法，允许开发者在特定时刻执行自定义操作。除此之外，它还包含了监控统计、任务队列操作等实用功能，每个功能的实现都是对execute()核心逻辑的扩展和优化。

       总的来说，ThreadPoolExecutor的execute()方法是整个线程池的核心，它的实现原理复杂而精细。后续将陆续分析ExecutorService和ScheduledThreadPoolExecutor的源码，深入探讨线程池的扩展和调度机制。敬请关注，期待下文的详细解析。

Java多线程:JUC并发工具原理

       ä¸€.前言

       è¶ç€æœ‰ç©º,赶紧把之前欠的债还上.这是多线程一阶段计划的最后一篇,后续多线程会转入修订和深入阶段.彻底吃透多线程.

二.工具介绍

       ä¹‹å‰è¯´AQS的时候曾经提到过这几个类,这几个类有一些各自的特点,很符合特定的场景,之前在生产上用的还挺舒服.

       æˆ‘们一般使用的并发工具有四种:

       CyclicBarrier:放学一起走

       å…è®¸ä¸€ç»„线程互相等待，直到到达某个公共屏障点(commonbarrierpoint)

       è®©ä¸€ç»„线程到达一个屏障时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活

       CountDownLatch:等人到齐了就触发

       åœ¨å®Œæˆä¸€ç»„正在其他线程中执行的操作之前，它允许一个或多个线程一直等待

       ç”¨ç»™å®šçš„计数初始化CountDownLatch。

       ç”±äºŽè°ƒç”¨äº†countDown()方法，所以在当前计数到达零之前，await方法会一直受阻塞。

       ä¹‹åŽï¼Œä¼šé‡Šæ”¾æ‰€æœ‰ç­‰å¾…的线程，await的所有后续调用都将立即返回。这种现象只出现一次——计数无法被重置。

       CountDownLatch是通过一个计数器来实现的，当我们在new一个CountDownLatch对象的时候需要带入该计数器值，该值就表示了线程的数量。

       æ¯å½“一个线程完成自己的任务后，计数器的值就会减1。当计数器的值变为0时，就表示所有的线程均已经完成了任务

       Semaphore

       ä¿¡å·é‡Semaphore是一个控制访问多个共享资源的计数器，和CountDownLatch一样，其本质上是一个“共享锁”。

       Exchanger

       å¯ä»¥åœ¨å¯¹ä¸­å¯¹å…ƒç´ è¿›è¡Œé…å¯¹å’Œäº¤æ¢çš„线程的同步点

       æ¯ä¸ªçº¿ç¨‹å°†æ¡ç›®ä¸Šçš„某个方法呈现给exchange方法，与伙伴线程进行匹配，并且在返回时接收其伙伴的对象,Exchanger可能被视为SynchronousQueue的双向形式

三.原理解析3.1CyclicBarrier

       ä½œç”¨:

       å®ƒå…è®¸ä¸€ç»„线程互相等待，直到到达某个公共屏障点(CommonBarrierPoint)。在涉及一组固定大小的线程的程序中，这些线程必须不时地互相等待，此时CyclicBarrier很有用。因为该Barrier在释放等待线程后可以重用，所以称它为循环(Cyclic)的屏障(Barrier)。

       å†…部原理:

       å†…部使用重入锁ReentrantLock和Condition

       æž„造函数:

       CyclicBarrier(intparties)：

       åˆ›å»ºä¸€ä¸ªæ–°çš„CyclicBarrier，它将在给定数量的参与者（线程）处于等待状态时启动，

       ä½†å®ƒä¸ä¼šåœ¨å¯åŠ¨barrier时执行预定义的操作。

       CyclicBarrier(intparties,RunnablebarrierAction)：

       åˆ›å»ºä¸€ä¸ªæ–°çš„CyclicBarrier，它将在给定数量的参与者（线程）处于等待状态时启动，

       å¹¶åœ¨å¯åŠ¨barrier时执行给定的屏障操作，该操作由最后一个进入barrier的线程执行。

       ä½¿ç”¨å˜é‡:

       parties变量:表示拦截线程的总数量。

       count变量:表示拦截线程的剩余需要数量。

       barrierAction变量:为CyclicBarrier接收的Runnable命令，用于在线程到达屏障时，优先执行barrierAction，用于处理更加复杂的业务场景。

       generation变量:表示CyclicBarrier的更新换代

//常用方法:M-await:等待状态M-await(longtimeout,TimeUnitunit):等待超时M-dowait-该方法第一步会试着获取锁-如果分代已经损坏，抛出异常-如果线程中断，终止CyclicBarrier-进来线程，--count-count==0表示所有线程均已到位，触发Runnable任务-唤醒所有等待线程，并更新generation>跳出等待状态的方法-最后一个线程到达，即index==0-超出了指定时间（超时等待）-其他的某个线程中断当前线程-其他的某个线程中断另一个等待的线程-其他的某个线程在等待barrier超时-其他的某个线程在此barrier调用reset()方法。reset()方法用于将屏障重置为初始状态。SC-Generation:描述了CyclicBarrier的更新换代。-在CyclicBarrier中，同一批线程属于同一代。-当有parties个线程全部到达barrier时，generation就会被更新换代。-其中broken属性，标识该当前CyclicBarrier是否已经处于中断状态M-breakBarrier:终止所有的线程M-nextGeneration:更新换代操作-1.唤醒所有线程。-2.重置count。-3.重置generation。M-reset:重置barrier到初始化状态M-getNumberWaiting:获得等待的线程数M-判断CyclicBarrier是否处于中断

       ä½¿ç”¨æ¡ˆä¾‹:

       GiteeCyclicBarrier使用

       é—®é¢˜è¡¥å……:

//问题一:拦截的核心1.传入总得Count数2.每次进来都会--count,同时判断count==.如果不为0,当前线程就会阻塞//问题二:涉及源码privatefinalReentrantLocklock=newReentrantLock();privatefinalConditiontrip=lock.newCondition();3.2CountDownLatch

       åœ¨å®Œæˆä¸€ç»„正在其他线程中执行的操作之前，它允许一个或多个线程一直等待

       ç”¨ç»™å®šçš„计数初始化CountDownLatch。由于调用了countDown()方法，所以在当前计数到达零之前，await方法会一直受阻塞。之后，会释放所有等待的线程，await的所有后续调用都将立即返回。这种现象只出现一次,计数无法被重置。如果需要重置计数，请考虑使用CyclicBarrier。

       CountDownLatch是通过一个计数器来实现的，当我们在new一个CountDownLatch对象的时候需要带入该计数器值，该值就表示了线程的数量。每当一个线程完成自己的任务后，计数器的值就会减1。当计数器的值变为0时，就表示所有的线程均已经完成了任务

//内部主要方法>CountDownLatch内部依赖Sync实现，而Sync继承AQS>sync::tryAcquireShared获取同步状态:tryReleaseShared释放同步状态>await():使当前线程在锁存器倒计数至零之前一直等待，除非线程被中断:sync.acquireSharedInterruptibly(1);:内部使用AQS的acquireSharedInterruptibly(intarg)>getState():获取同步状态，其值等于计数器的值:从这里我们可以看到如果计数器值不等于0，则会调用doAcquireSharedInterruptibly(intarg)>doAcquireSharedInterruptibly:自旋方法会尝试一直去获取同步状态>countDown:CountDownLatch提供countDown()方法递减锁存器的计数，如果计数到达零，则释放所有等待的线程:内部调用AQS的releaseShared(intarg)方法来释放共享锁同步状态:tryReleaseShared(intarg)方法被CountDownLatch的内部类Sync重写

       å‚考案例

       GiteeCountDownLatch使用

       æ€»ç»“

       CountDownLatch内部通过共享锁实现。在创建CountDownLatch实例时，需要传递一个int型的参数：count，该参数为计数器的初始值，也可以理解为该共享锁可以获取的总次数。

       å½“某个线程调用await()方法，程序首先判断count的值是否为0，如果不会0的话则会一直等待直到为0为止(PS:可以多个线程都调用await)

       å½“其他线程调用countDown()方法时，则执行释放共享锁状态，使count值–1(PS:countDown并不会阻塞)

       å½“在创建CountDownLatch时初始化的count参数，必须要有count线程调用countDown方法才会使计数器count等于0，锁才会释放，前面等待的线程才会继续运行。注意CountDownLatch不能回滚重置

3.3Semaphore

       åŸºç¡€ç‚¹

       ä¿¡å·é‡Semaphore是一个控制访问多个共享资源的计数器，和CountDownLatch一样，其本质上是一个“共享锁”。

       ä»Žæ¦‚念上讲，信号量维护了一个许可集。如有必要，在许可可用前会阻塞每一个acquire()，然后再获取该许可。每个release()添加一个许可，从而可能释放一个正在阻塞的获取者。

       Semaphore通常用于限制可以访问某些资源（物理或逻辑的）的线程数目

       å½“一个线程想要访问某个共享资源时，它必须要先获取Semaphore，当Semaphore>0时，获取该资源并使Semaphore–1。如果Semaphore值=0，则表示全部的共享资源已经被其他线程全部占用，线程必须要等待其他线程释放资源。当线程释放资源时，Semaphore则+1

       å®žçŽ°ç»†èŠ‚

       Semaphore提供了两个构造函数：

       Semaphore(intpermits)：创建具有给定的许可数和非公平的公平设置的Semaphore。

       Semaphore(intpermits,booleanfair)：创建具有给定的许可数和给定的公平设置的Semaphore。

       Semaphore默认选择非公平锁。

       å½“信号量Semaphore=1时，它可以当作互斥锁使用。其中0、1就相当于它的状态，当=1时表示其他线程可以获取，当=0时，排他，即其他线程必须要等待。

//------信号量获取>acquire()方法来获取一个许可:内部调用AQS的acquireSharedInterruptibly(intarg)，该方法以共享模式获取同步状态>公平:判断该线程是否位于CLH队列的列头:获取当前的信号量许可:设置“获得acquires个信号量许可之后，剩余的信号量许可数”:CAS设置信号量>非公平:不需要判断当前线程是否位于CLH同步队列列头3.4Exchanger

       å¯ä»¥åœ¨å¯¹ä¸­å¯¹å…ƒç´ è¿›è¡Œé…å¯¹å’Œäº¤æ¢çš„线程的同步点

       æ¯ä¸ªçº¿ç¨‹å°†æ¡ç›®ä¸Šçš„某个方法呈现给exchange方法，与伙伴线程进行匹配，并且在返回时接收其伙伴的对象,Exchanger可能被视为SynchronousQueue的双向形式

       Exchanger，它允许在并发任务之间交换数据:当两个线程都到达同步点时，他们交换数据结构，因此第一个线程的数据结构进入到第二个线程中，第二个线程的数据结构进入到第一个线程中

       TODO:Exchanger的源代码比较绕,而且这个组件使用场景并不多,所以先留个坑,以后项目上真的有场景了再实际上分析一下

3.5并发工具使用

       @github.com/black-ant/case/tree/master/case%Module%Thread/case%thread_utils

补充:#CountDownLatch和CyclicBarrier如何理解?

       CyclicBarrier:小学生去郊游,老师下车时统计人数,人数到齐了才能一起参观

       CountDownLatch:幼儿园老师送孩子(ChildThread)放学,走一个记一个数,当所有的学生放学后,老师(BossThread)下班

//核心解释:CyclicBarrier就是一堵墙,人数到了所有线程才能一起越过墙CountDownLatch只是一个计数器,数目到了主线程才能执行//其他要点:CyclicBarrier可以重置计数,CountDownLatch不可以总结

       ç»ˆäºŽè¡¥ä¸Šäº†æœ€åŽä¸€å—板,后面来真正的深入多线程看看吧,争取早日成为多线程大师段位

更新记录

       :优化布局

       ä½œè€…：AntBlack