class SessionCleaner implements Runnable {

    private SessionManager sessionManager;

    public SessionCleaner(SessionManager sessionManager) {
        this.sessionManager = sessionManager;
    }

    @Override
    public void run() {<FILL_FUNCTION_BODY>}

    private boolean expires(Session session) {
        long now = Instant.now().getEpochSecond();
        return session.expired() < now;
    }

}

        try {
            Collection<Session> sessions = sessionManager.sessionMap().values();
            sessions.parallelStream().filter(this::expires).forEach(sessionManager::destroySession);
        } catch (Exception e) {
            log.error("Session clean error", e);
        }
    
<no_super_class>