Alejandro M. BERNARDIS alejandrobernardis

Asynchronous programming with Tornado

Asynchronous programming can be tricky for beginners, therefore I think it's useful to iron some basic concepts to avoid common pitfalls.

For an explanation about generic asynchronous programming, I recommend you one of the [many][2] [resources][3] [online][4].

I will focus on solely on asynchronous programming in [Tornado][1]. From Tornado's homepage:


	var gulp = require('gulp');
	var stylus = require('gulp-stylus');
	var browser_sync = require('browser-sync');
	var reload = browser_sync.reload;

	gulp.task('stylus', function() {
	return gulp.src('./static/css/*.styl')
	.pipe(stylus())
	.pipe(gulp.dest('./static/css'))

	yum -y update \
	&& yum -y upgrade \
	&& yum -y groupinstall "Development tools" \
	&& yum -y install nano wget tree vim \
	&& rpm -iUvh http://dl.fedoraproject.org/pub/epel/7/x86_64/e/epel-release-7-5.noarch.rpm


	from tornado import gen, ioloop
	from tornado.httpclient import AsyncHTTPClient

	@gen.coroutine
	def worker():
	sites = ['http://google.com', 'http://clarin.com', 'http://lanacion.com']

	@gen.coroutine
	def _bulk():

	#!/usr/bin/env python2.7
	# -- coding: utf-8 --
	# Copyright (c) 2014 Asumi Kamikaze Inc.
	# Licensed under the MIT License.
	# Author: Alejandro M. Bernardis
	# Email: alejandro (dot) bernardis (at) asumikamikaze (dot) com
	# Created: 20/Oct/2014 11:59

	import datetime


	from random import randint
	from collections import deque

	MIXPANEL_EVENTS = 'events'
	MIXPANEL_PEOPLE = 'people'
	MIXPANEL_IMPORTS = 'imports'

	MIXPANEL_ENDPOINTS = {
	MIXPANEL_EVENTS: 'https://api.mixpanel.com/track',

	from concurrent.futures import ThreadPoolExecutor
	from tornado import gen
	from tornado.process import cpu_count
	import bcrypt

	# global threadpool
	pool = ThreadPoolExecutor(cpu_count())

	@gen.coroutine
	def create_user(name, password):

	import concurrent.futures


	class ProcessManager(object):

	def __init__(self):
	self.pool = concurrent.futures.ProcessPoolExecutor()
	self.futures = {}

	def submit(self, f, args, *kwargs):