Как вернуть значения из списка в round robin в многопоточной среде?

Question

Мне нужно написать код, который включает асинхронный вызов веб-службы на бэкэнд и возврат бесплатного номера в циклическом роуминге из списка TFN для вызывающего. Ниже мой код

@Stateless 
public class TollFreeServiceBean { 
    @EJB 
    private AsyncBackendService asyncBean; 
    public long getTollFreeNumber(Request request) { 
     //Validate request 
     asyncBean.callBackend(request); 
     return TFNUtil.getNext(); 
    } 
} 

@Stateless 
public class AsyncBackendService { 
    @Asynchronous 
    public void callBackend(Request request) { 
     // Call web service and inform a caller with `Request` is going to call 
    } 
} 

public class TFNUtil { 
    private static int index = 0; 
    private TFNUtil(){} 
    public static synchronized long getNext() { 
     // Get TFN list from cache 
     if(tfnList.size() >= index) { 
      index = 0; 
     } 
     long tfn = tfnList.get(index); 
     index++; 
     return tfn; 
    } 
} 

Идея заключается в том, что клиенты будут получать различный TFN каждый, пока TFNs в кэше будет завершен. После завершения следующего клиента новый TFN снова получит. Например, если 10 TFN и 11 клиентов, 11-й клиент должен получить 1-й TFN. 12-й клиент должен получить 2-й TFN и так далее.

Бэкэнд-система жалуется, что два разных одновременных клиента высаживаются на тот же TFN. Поэтому я думаю, что моя логика TFNUtil.getNext() неверна.

Может ли кто-нибудь указать на ошибку здесь?

Answer 1

Ваши заявления противоречат друг другу.

С одной стороны, вы беспокоитесь, что ни один из двух клиентов не должен получать номер.

С другой стороны, вы намеренно устанавливаете систему на место, которая точно это сделает.

Вы видите, в зависимости от количества элементов вашего списка tfnList имеет ... ваш метод getNext() может «пролить» довольно быстро. И что, по-вашему, произойдет?

Для меня это похоже на то, что реальное решение сложнее: вам, возможно, придется перепроектировать вашу систему. Вместо того, чтобы просто поворачивать этот список чисел, вам может понадобиться система, которая может заблокировать/зарезервировать номер в течение некоторого времени. И пока номер зарезервирован, он не раздается снова.

Простая версия этого будет «только время»; что означает, что бронирование «исчезает» автоматически через несколько минут или часов. Если это не сработает; вам нужно пойти еще на один шаг: и найти что-то/кого-то в вашем рабочем процессе, чтобы до un зарезервировать номера, чтобы они снова были «доступны».

И, кроме того, кажется, что вы не полностью учли, что должно произойти, когда у вас есть номера N, но клиенты N + x входят в одно и то же время! Никакой круговой поворот/поворот ... все, что может вам помочь! Если такая ситуация возможна, тогда вам придется иметь дело с ней и определить, что должно произойти тогда!