Android房间等待插入完成

@Dao
public interface UserDao {
    @Insert(onConflict = OnConflictStrategy.REPLACE)
    void insertUser(User user);

    @Query("SELECT * FROM users")
    LiveData<List<User>> getUsers();
}

public class UserRepository {
    private UserDao userDao;

    public UserRepository(UserDao userDao) {
        this.userDao = userDao;
    }

    public void insertUser(User user) {
        CompletableFuture.runAsync(() -> userDao.insertUser(user));
    }

    public LiveData<List<User>> getUsers() {
        return userDao.getUsers();
    }
}

// 在使用时
UserRepository userRepository = new UserRepository(userDao);
User user = new User("John", "Doe");
userRepository.insertUser(user);

// 等待插入完成后获取数据
userRepository.getUsers().observe(this, userList -> {
    // 处理获取到的数据
});