java多線程

1.并發與并行
并發：
指兩個或多個事情在同一個時間段內產生。
并行:
并行：指兩個或多個事情在同一時間產生（同時產生）。
2.線程與進程
進程：
是指一個內存中運轉的應用程序，每個進程都有一個獨立的內存空間，一個應用程序能夠同時運轉多個進程；進程也是程序的一次履行進程，是體系運轉程序的基本單位；體系運轉一個程序便是一個進程從創立、運轉到消亡的進程。
線程：
線程是進程中的一個履行單元，負責當時進程中程序的履行，一個進程中至少有一個線程。一個進程中是能夠有多個線程的，這個應用程序也能夠稱之為多線程程序。
線程的創立
構造辦法：
publicThread():分配一個新的線程目標。
publicThread(Stringname):分配一個指定姓名的新的線程目標。
publicThread(Runnabletarget):分配一個帶有指定目標新的線程目標。
publicThread(Runnabletarget,Stringname):分配一個帶有指定目標新的線程目標并指定姓名。
一些常見的辦法：
publicStringgetName():獲取當時線程稱號。
publicvoidstart():導致此線程開始履行;Java虛擬機調用此線程的run辦法。
publicvoidrun():此線程要履行的任務在此處界說代碼。
publicstaticvoidsleep(longmillis):使當時正在履行的線程以指定的毫秒數暫停（暫時間斷履行）。
publicstaticThreadcurrentThread():返回對當時正在履行的線程目標的引用。
wait（）辦法
wait辦法的效果便是使當時履行的代碼進行等候，wait()辦法便是Object類的辦法，該辦法是用來將當時線程置入”預履行隊列中”，并且在wait辦法()所在的代碼處間斷履行，直到接到通知或被中斷間斷
wait辦法只能在同步辦法中或同步塊中調用。如果調用的wait時，沒有持有恰當的鎖，會拋出異常。
wait（）辦法履行后，當時線程釋放鎖，線程與其它線程競爭重新獲取鎖。
notify（）辦法
notify辦法便是使間斷的線程持續運轉
辦法notify()也要在同步辦法或同步塊中調用，該辦法是用來通知那些可能等候該目標的目標鎖的其它線程，對其發出通知notify，并使它們重新獲取該目標的目標鎖。如果有多個線程等候，則有線程規劃器隨機挑選出一個呈wait狀況的的線程。
在notify()辦法后，當時線程不會馬上釋放該目標鎖，要比及履行notify()辦法的線程將程序履行完，也便是退出同步代碼塊之后才會釋放目標鎖。
查看線程的運轉狀況
線程有六種狀況分別是：新建、運轉、堵塞、等候、計時等候和停止
完成思路：
創立一個類;ThreadState,完成Runnable接口
界說三個辦法：
.waitForASecond()：使當時線程等候0.5秒或其他線程調用notify()或notifyAll()辦法
.waitForYears();使當時線程永久等候，直到其他線程調用notify()或notifyAll()辦法
.notifyNow():喚醒由調用wait辦法()進入等候狀況的線程

spring實現多線程

由于本周大部分時刻都在寫原型，首要遇到的問題就是對實踐功用理解不精確導致多次修正原型浪費了很多時刻，這也就告知咱們一定要清晰實踐要求再去下手。
由于之前會議中也多次提到了線程，而我本人對線程沒有什么理解于是便有了以下文章。
為什么運用多線程
在咱們開發體系過程中，經常會處理一些費時刻的使命（如：向數據庫中刺進很多數據），這個時候就就需要運用多線程。
Springboot中是否對多線程辦法進行了封裝
是，Spring中可直接由@Async完成多線程操作
如何操控線程運行中的各項參數
通過裝備線程池。
線程池ThreadPoolExecutor履行規矩如下
然后咱們來以為構造一個線程池來試一下：
@Configuration
@EnableAsync
publicclassThreadPoolConfigimplementsAsyncConfigurer{
/**
*中心線程池巨細
*/
privatestaticfinalintCORE_POOL_SIZE=3;
/**
*最大可創立的線程數
*/
privatestaticfinalintMAX_POOL_SIZE=10;
/**
*行列最大長度
*/
privatestaticfinalintQUEUE_CAPACITY=10;
/**
*線程池保護線程所答應的閑暇時刻
*/
privatestaticfinalintKEEP_ALIVE_SECONDS=300;
/**
*異步履行辦法線程池
*
*@return
*/
@Override
@Bean
publicExecutorgetAsyncExecutor(){
ThreadPoolTaskExecutorexecutor=newThreadPoolTaskExecutor();
executor.setMaxPoolSize(MAX_POOL_SIZE);
executor.setCorePoolSize(CORE_POOL_SIZE);
executor.setQueueCapacity(QUEUE_CAPACITY);
executor.setKeepAliveSeconds(KEEP_ALIVE_SECONDS);
executor.setThreadNamePrefix(“LiMingTest”);
//線程池對回絕使命(無線程可用)的處理戰略
executor.setRejectedExecutionHandler(newThreadPoolExecutor.CallerRunsPolicy());
executor.initialize();
returnexecutor;
}
}
ThreadPoolExecutor是JDK中的線程池完成，這個類完成了一個線程池需要的各個辦法，它提供了使命提交、線程辦理、監控等辦法。
corePoolSize：中心線程數
線程池保護的最小線程數量，默許情況下中心線程創立后不會被收回（注意：設置allowCoreThreadTimeout=true后，閑暇的中心線程超過存活時刻也會被收回）。
大于中心線程數的線程，在閑暇時刻超過keepAliveTime后會被收回。
maximumPoolSize：最大線程數
線程池答應創立的最大線程數量。
當增加一個使命時，中心線程數已滿，線程池還沒達到最大線程數，并且沒有閑暇線程，作業行列已滿的情況下，創立一個新線程，然后從作業行列的頭部取出一個使命交由新線程來處理，而將剛提交的使命放入作業行列尾部。
keepAliveTime：閑暇線程存活時刻
當一個可被收回的線程的閑暇時刻大于keepAliveTime，就會被收回。
被收回的線程：
設置allowCoreThreadTimeout=true的中心線程。
大于中心線程數的線程（非中心線程）。
workQueue：作業行列
新使命被提交后，假如中心線程數已滿則會先增加到作業行列，使命調度時再從行列中取出使命。作業行列完成了BlockingQueue接口。
handler：回絕戰略
當線程池線程數已滿，并且作業行列達到約束，新提交的使命運用回絕戰略處理。可以自定義回絕戰略，回絕戰略需要完成RejectedExecutionHandler接口。
JDK默許的回絕戰略有四種：
AbortPolicy：丟掉使命并拋出RejectedExecutionException反常。
DiscardPolicy：丟掉使命，但是不拋出反常。或許導致無法發現體系的反常狀況。
DiscardOldestPolicy：丟掉行列最前面的使命，然后重新提交被回絕的使命。
CallerRunsPolicy：由調用線程處理該使命。
咱們在非測驗文件中直接運用newThread創立新線程時編譯器會發出正告:
不要顯式創立線程，請運用線程池。
闡明：運用線程池的優點是減少在創立和毀掉線程上所花的時刻以及體系資源的開銷，解決資源缺乏的問題。假如不運用線程池，有或許造成體系創立很多同類線程而導致耗費完內存或者“過度切換”的問題
publicclassTestServiceImplimplementsTestService{
privatefinalstaticLoggerlogger=LoggerFactory.getLogger(TestServiceImpl.class);
@Override
publicvoidtask(inti){
logger.info(“使命:”+i);
}
}
@Autowired
TestServicetestService;
@Test
publicvoidtest(){
for(inti=0;i<50;i++){
testService.task(i);
}
咱們可以看到全部履行正常；
之后我有對線程進行了一些測驗：
classTestServiceImplTest{
@Test
publicvoidtest(){
Threadadd=newAddThread();
Threaddec=newDecThread();
add.start();
dec.start();
add.join();
dec.join();
System.out.println(Counter.count);
}
staticclassCounter{
publicstaticintcount=0;
}
classAddThreadextendsThread{
publicvoidrun(){
for(inti=0;i<10000;i++){Counter.count+=1;}
}
}
classDecThreadextendsThread{
publicvoidrun(){
for(inti=0;i<10000;i++){Counter.count-=1;}
}
}
一個自增線程，一個自減線程，對0進行同樣次數的操作，理應成果仍然為零，但是履行成果卻每次都不同。
通過查找之后發現對變量進行讀取和寫入時，成果要正確，有必要確保是原子操作。原子操作是指不能被中止的一個或一系列操作。
例如，關于句子：n+=1;看似只要一行句子卻包含了3條指令：
讀取n,n+1,存儲n;
比方有以下兩個進程一起對10進行加1操作
這闡明多線程模型下，要確保邏輯正確，對同享變量進行讀寫時，有必要確保一組指令以原子方式履行：即某一個線程履行時，其他線程有必要等候。
staticclassCounter{
publicstaticfinalObjectlock=newObject();//每個線程都需獲得鎖才干履行
publicstaticintcount=0;
}
classAddThreadextendsThread{
publicvoidrun(){
for(inti=0;i<10000;i++){
synchronized(Counter.lock){staticclassCounter{
publicstaticfinalObjectlock=newObject();
publicstaticintcount=0;
}
classDecThreadextendsThread{
publicvoidrun(){
for(inti=0;i<10000;i++){
synchronized(Counter.lock){
Counter.count-=1;
}
}
}
}
值得注意的是每個類可以設置多個鎖，假如線程獲取的不是同一個鎖則無法起到上述功用；
springBoot中也定義了很多類型的鎖，在此就不逐個闡明晰，咱們目前能做到的就是注意項目中的異步操作，調查操作所運用的線程，做到在今后項目中遇到此類問題時能及時發現問題，解決問題。