ВС
Вот был пример использования LinkedBlockedQueue для синхронизации потоков.
Пример в коде был такой:
Метод take хорош тем, что пока очередь пустая, код будет ждать начала появления элемента в ней. А как основной поток положил что-то в очередь - метод продолжит работу.
И этот код можно упростить до такого:
Пример в коде был такой:
import java.util.concurrent.ConcurrentHashMap;...
import java.util.concurrent.LinkedBlockingQueue;
ConcurrentHashMap map = props.get('data')
LinkedBlockingQueue in_game_users = map.get('in_game_users');
log.info(' PERVIY DO = ' + in_game_users.toString())
def pio
pio = in_game_users.take();
Метод take хорош тем, что пока очередь пустая, код будет ждать начала появления элемента в ней. А как основной поток положил что-то в очередь - метод продолжит работу.
И этот код можно упростить до такого:
import java.util.concurrent.LinkedBlockingQueue;...
LinkedBlockingQueue q = props.get('q')
def data = q.take();
