process.java

gistfile1.txt

    public void init() throws InitializationException {
        lockActuator.init();
        modemController.init();
        modemController.addPhoneCallListener((phoneNumber) -> {
                eventQueue.offer(new PhoneCallEvent(phoneNumber));
        });
    }

    @Override
    @SuppressWarnings("SleepWhileInLoop")
    public void run() {
        thread.set(Thread.currentThread());
        running.set(true);
        log.info("Lock mechanism started");
        while (running.get()) {
            try {
                PhoneCallEvent event = eventQueue.take();
                if (memberLookup.isAuthorizedMember(event.getPhoneNumber())) {
                    lockActuator.setLockOpen(true);
                    Thread.sleep(lockOpenTime);
                }
                if (Thread.interrupted()) {
                    throw new InterruptedException();
                }
            } catch (InterruptedException ex) {
                log.info("Lock mechanism interrupted");
            } finally {
                lockActuator.setLockOpen(false);
            }
        }
        log.info("Lock mechanism stopped");
        thread.set(null);
    }