在不同线程中更新数据库

Question

我有一个cron作业每30秒运行一次，检查未结束的游戏。我将ExecutorService用于固定线程池private ExecutorService executor=executors.NewFixedThreadpool（2）；。cron作业调用此方法：

    public void initializeForStreaming(Game game) {
        dispatching.add(game.getPlatformGameId());
        Failsafe.with(retryPolicy).with(executor).runAsync(() -> {
            Game updatedGame = gameService.updateGameStatus(game.getId(), GameStatus.STREAMING);
            log.info("{} - game {} was changed to status {}", Thread.currentThread().getName(), game
                            .getName(),
                    GameStatus.STREAMING);
            streamingService.pollStreamedGames(StreamedGames.builder().game(updatedGame).build());
        }).exceptionally((e) -> {
            log.error("Failed to poll game: {}", e.getMessage(), e);
            return null;
        }).thenRun(() -> {
            dispatching.remove(game.getPlatformGameId());
            gameService.updateGameStatus(game.getId(), GameStatus.ENDED);
            log.info("{} - game {} was changed to status {}", Thread.currentThread().getName(), game
                            .getName(),
                    GameStatus.ENDED);
        });
    }

其中department是concurrentskiplistset。在PollStreadGames方法内部，我在do-while循环中调用一个api，直到没有下一个页面。在这个方法中，我想更新数据库，以记住我最后看到的页面。

@Override
    public void pollStreamedGames(StreamedGames streamedGames) {
        try {
            ...
            do {
                ...
                if (!response.getEvents().isEmpty()) {
                    pagesThisIteration++;
                    CompletableFuture.runAsync(() -> {
                                gameService.updateCurrentGamePosition(streamedGames.getGame());
                            }
                    );
                    sleep(5000);
                }
            } while (response.getNextPageToken() != null);
        } catch (ResourceAccessException e) {
            log.error("reading API failed: {}", e.getMessage(), e);
        }
    }

是否可以在一个线程中更新数据库，然后启动另一个线程，其中数据库再次更新？

Answer 1

答案是，您可以这样做，但风险较小（如果在上面两种情况下使用单线程进行更新，风险会小一些），因为您使用的是并行处理。最好用一个线程同时完成这两个操作。在使用并行处理更新带有主键的记录集之前，我会三思而后行。但是，我建议您使用下面这样的批处理：

map employeeMap=new hashmap ()；EmployeeMap.Add（某物）；

int empsize=employeeMap.size()；

对于（int i=0；i

int id=EmployeeMap.getPrimaryKey（）；--这是您要做的

字符串emp[]=新字符串[id]；

从表t中更新id，其中t.id在(EMP[])中；

}

这是一种同步方式的批处理，它降低了并行处理复杂性的风险。