春季長輪詢ConcurrentModificationException

Question

基本上我有一個簡單的新聞應用程序，現在我想有新聞列表自動更新所有用戶每當有人添加或刪除新聞時，它有點工作，但有時我得到ConcurrentModificationException，我只需要編寫此方法的幫助：

@GetMapping("/pollnews") 
@ResponseBody 
public DeferredResult<ModelAndView> poll(Model model){ 
    DeferredResult<ModelAndView> result = new DeferredResult<>(); 
    new Thread(new Runnable() { 

     @Override 
     public void run() { 
      while(true){ 
       if(changeOccured){ 
        changeOccured = false; 
        model.addAttribute("news", newsService.getAllNews()); 
        result.setResult(new ModelAndView("partial")); 
        break; 
       } 
      } 
     } 
    }).start(); 
    return result; 
} 

堆棧跟蹤：

Exception in thread "Thread-13" java.util.ConcurrentModificationException 
at java.util.ArrayList.sort(ArrayList.java:1456) 
at com.newsapp.SpringNews.Service.NewsService.getAllNews(NewsService.java:25) 
at com.newsapp.SpringNews.Controller.ViewController$1.run(ViewController.java:125) 
at java.lang.Thread.run(Thread.java:748) 

Answer 1

您使用ArrayList將數據寫入和concurently獲取數據。 ArrayList將會失敗。你需要的是管理concurent訪問List實現：

• 要麼你創建你的列表，如：表< ..>列表= Collections.synchronizedList（新的ArrayList <>（））;
• 或者你使用真正的concurent列表像http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CopyOnWriteArrayList.html

無論如何，拉一樣，是非常危險的 - 你會打網絡超時，你還會殺了你有很多線程的循環上，而真正的服務器（上你的代碼沒有等待！）。

一個更好的方法是使用ServerSideEvent（SSE）和事件系統。

這裏做的是帶彈簧https://golb.hplar.ch/p/Server-Sent-Events-with-Spring

它管理事件系統，使聽衆和生產完全分離後。