Сергей Горностаев

def response_handler(response, url_id):
    print(response.url)

results = grequests.map(
  (grequests.get(u["url"], callback=lambda r, uid=u['id'], **kw: response_handler(r, uid)) for u in urls))

reader     writer  состояние
---------- ------ ------------
перед x=0          x=1, y=2
             x=1   x=1, y=2
x=0                x=0, y=2
y=0                x=0, y=0
             y=2   x=0, y=2

$ python manage.py shell

In [1]: from some_app.stata import get_ida_instance
In [2]: get_ida_instance()

@RequestMapping(...)
public String home(Model model, Principal principal) {
    ...
}

Principal principal = SecurityContextHolder.getContext().getAuthentication().getPrincipal();

for port in ports:
    threading.Thread(target=PortCheck, args = [port]).start()

for t in threading.enumerate():          # Получаем все потоки
    if t != threading.current_thread():  # Если это не текущий поток
        t.join()                         # Ожидаем его завершения

print('--------------------------------------')
input('Process ended. Press Enter.' + '\n')