Java多線程併發同步執行

http://www.javashuo.com/article/p-akntyrrn-de.html

併發關鍵字：volatile，final，synchronized

Collections: 併發集合

Executors: 線程池

synchronized

對象鎖是用來控制實例方法之間的同步

類鎖是用來控制靜態方法（或靜態變量互斥體）之間的同步

對象鎖：Java的全部對象都含有1個互斥鎖，這個鎖由JVM自動獲取和釋放。線程進入synchronized方法的時候獲取該對象的鎖，固然若是已經有線程獲取了這個對象的鎖，那麼當前線程會等待；synchronized方法正常返回或者拋異常而終止，JVM會自動釋放對象鎖。這裏也體現了用synchronized來加鎖的1個好處，方法拋異常的時候，鎖仍然能夠由JVM來自動釋放。

 

類鎖：對象鎖是用來控制實例方法之間的同步，類鎖是用來控制靜態方法（或靜態變量互斥體）之間的同步。其實類鎖只是一個概念上的東西，並非真實存在的，它只是用來幫助咱們理解鎖定實例方法和靜態方法的區別的。java類可能會有不少個對象，可是隻有1個Class對象，也就是說類的不一樣實例之間共享該類的Class對象。Class對象其實也僅僅是1個java對象，只不過有點特殊而已。因爲每一個java對象都有1個互斥鎖，而類的靜態方法是須要Class對象。因此所謂的類鎖，不過是Class對象的鎖而已。

 

類鎖和對象鎖不是同1個東西，一個是類的Class對象的鎖，一個是類的實例的鎖。也就是說：1個線程訪問靜態synchronized的時候，容許另外一個線程訪問對象的實例synchronized方法。反過來也是成立的，由於他們須要的鎖是不一樣的。

 

 

（1）CyclicBarrier的某個線程運行到某個點上以後，該線程即中止運行，直到全部的線程都到達了這個點，全部線程才從新運行；CountDownLatch則不是，某線程運行到某個點上以後，只是給某個數值-1而已，該線程繼續運行

 

（2）CyclicBarrier只能喚起一個任務，CountDownLatch能夠喚起多個任務

 

（3）CyclicBarrier可重用，CountDownLatch不可重用，計數值爲0該CountDownLatch就不可再用了 

 

將串行調用改成並行調用, 在有限併發級別下, 能極大提升性能

@Component

public class UserQueryFacade {

@Autowired

private FollowService followService;

@Autowired

private PostService postService;

@Autowired

private UserService userService;

 

public User getUserDataByParallel(Long userId) throws InterruptedException, ExecutionException {

ExecutorService executorService = Executors.newFixedThreadPool(3);

CountDownLatch countDownLatch = new CountDownLatch(3);

Future<User> userFuture = executorService.submit(() -> {

try{

return userService.get(userId);

}finally {

countDownLatch.countDown();

}

});

Future<List<Post>> postsFuture = executorService.submit(() -> {

try{

return postService.getPosts(userId);

}finally {

countDownLatch.countDown();

}

});

Future<List<User>> followersFuture = executorService.submit(() -> {

try{

return followService.getFollowers(userId);

}finally {

countDownLatch.countDown();

}

});

countDownLatch.await();

User user = userFuture.get();

user.setFollowers(followersFuture.get());

user.setPosts(postsFuture.get());

return user;

}

}

 

http://www.javashuo.com/article/p-uoyybqrl-mu.html