Изучаем Java EE 7

@Lock(LockType.WRITE)

@AccessTimeout(value = 20, unit = TimeUnit.SECONDS)

public class CacheEJB {

··private Map cache = new HashMap<>();

··public void addToCache(Long id, Object object) {

····if (!cache.containsKey(id))

······cache.put(id, object);

··}

··public void removeFromCache(Long id) {

····if (cache.containsKey(id))

······cache.remove(id);

··}

··@Lock(LockType.READ)

··public Object getFromCache(Long id) {

····if (cache.containsKey(id))

······return cache.get(id);

····else

······return null;

··}

}

В листинге 7.11 класс снабжен аннотацией @AccessTimeout. При блокировке конкурентного доступа можно указать время ожидания для отклонения запроса, если блокировка не будет применена в течение определенного времени. Если вызов addToCache() станет блокироваться более 20 секунд, то для клиента будет сгенерировано исключение ConcurrentAccessTimeoutException.

Конкурентный доступ, управляемый EJB-компонентом

При использовании такого подхода, как конкурентный доступ, управляемый EJB-компонентом, контейнер разрешает полный конкурентный доступ к экземпляру одиночного EJB-компонента. Тогда вы будете отвечать за защиту его состояния от ошибок синхронизации вследствие конкурентного доступа. В этом случае вам будет разрешено использовать Java-примитивы синхронизации, например synchronized и volatile. В коде, приведенном в листинге 7.12, показан CacheEJB с конкурентным доступом, управляемым EJB-компонентом (@ConcurrencyManagement(BEAN)), при этом для методов addToCache() и removeFromCache() используется ключевое слово synchronized.

Листинг 7.12. Одиночный сессионный EJB-компонент с конкурентным доступом, управляемым EJB-компонентом

@Singleton

@ConcurrencyManagement(ConcurrencyManagementType.BEAN)

public class CacheEJB {

··private Map cache = new HashMap<>();

··public synchronized void addToCache(Long id, Object object) {

····if (!cache.containsKey(id))

······cache.put(id, object);

··}

··public synchronized void removeFromCache(Long id) {

····if (cache.containsKey(id))

······cache.remove(id);

··}

··public Object getFromCache(Long id) {

····if (cache.containsKey(id))

······return cache.get(id);

····else

······return null;

··}

}

Время ожидания конкурентного доступа и запрет конкурентного доступа

Попытка конкурентного доступа, при которой не может быть незамедлительно применена соответствующая блокировка, будет блокироваться до тех пор, пока не получится продвинуться вперед. Аннотация @AccessTimeout используется для определения периода, на протяжении которого должна блокироваться попытка доступа, прежде чем истечет время ожидания. Значение @AccessTimeout, равное -1, показывает, что клиентский запрос будет блокироваться неопределенно долго до тех пор, пока не получится продвинуться вперед. Значение @AccessTimeout, равное 0, говорит о том, что конкурентный доступ запрещен. В результате будет сгенерировано исключение ConcurrentAccessException, если клиент вызовет метод, используемый в текущий момент. Это может сказаться на производительности, поскольку клиентам, возможно, придется обработать исключение, снова попытаться получить доступ к EJB-компоненту, после чего вероятны генерирование еще одного исключения, новая попытка и т. д. В листинге 7.13 CacheEJB запрещает конкурентный доступ к методу addToCache(). Это означает, что если клиент А будет добавлять объект в кэш, а клиент В захочет сделать то же самое одновременно с ним, то для клиента В будет сгенерировано исключение и ему придется попытаться снова позднее (либо поступить с исключением по-другому).

Листинг 7.13. Одиночный сессионный EJB-компонент, запрещающий конкурентный доступ к методу

@Singleton

public class CacheEJB {

··private Map cache = new HashMap<>();

··@AccessTimeout(0)