Spring长轮询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 将失败。您需要一个管理并发访问的 List 实现：

• 您可以像这样创建列表：List<..> list=Collections.synchronizedList(new ArrayList());
• 或者你使用真正的并发列表，比如http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CopyOnWriteArrayList.html

无论如何，这样拉是非常危险的 - 你会遇到网络超时，你也会杀死你的服务器，在 while true 上会有很多线程循环（在你的代码上没有等待！）。

更好的方法是使用 ServerSideEvent (SSE) 和事件系统。

这里有一篇关于使用 spring https://golb.hplar.ch/p/Server-Sent-Events-with-Spring 的帖子

它管理一个事件系统，使监听器和生产者完全分离。