lbolla

from concurrent.futures import ThreadPoolExecutor
from functools import partial, wraps
import time

import tornado.ioloop
import tornado.web


EXECUTOR = ThreadPoolExecutor(max_workers=4)

lbolla

##############################################################################
#
# Simple Python program to benchmark several Python Excel writing modules.
#
# python bench_excel_writers.py [num_rows] [num_cols]
#
#

import sys
import resource

lbolla

javascript:(function() {var s=document.createElement('script'); s.src="https://raw.github.com/gist/1303423/4859b59a423612c90ec5b0c77591f984c4dfdd07/add_reviewers.js"; document.getElementsByTagName('head')[0].appendChild(s);})()

lbolla

import os
import time
from subprocess import Popen


def check_zombies(expected_nzombies):
    # NOTE: don't use Popen() here
    output = os.popen(r"ps aux | grep ' Z' | grep -v grep").read()
    got_nzombies = len(output.splitlines())
    if got_nzombies > 0:

lbolla

import concurrent.futures


class ProcessManager(object):

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

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

lbolla

[MyDB]
Description     = My Database
Driver          = FreeTDS
Servername      = W7WS6CL832J  # MSSQL server name
Database        = mydb
UID             = username
PWD             = password
Port            = 1433
Charset         = UTF-8

lbolla

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:

lbolla

import logging
import multiprocessing
import os
import random
import threading
import time
from typing import Optional

LOG_FMT = ('%(asctime)s %(levelname)s [%(name)s] '
           '<%(filename)s:%(funcName)s:%(lineno)d> '

lbolla

import gc
import os
import resource


def print_mem():
    u = resource.getrusage(resource.RUSAGE_SELF)
    print 'N={} RSS={}'.format(N, u.ru_maxrss)

lbolla

import sys
import tornado.ioloop
import psycopg2
import psycopg2.extensions

io_loop = tornado.ioloop.IOLoop.instance()
conn = psycopg2.connect('dbname=mytest user=lbolla password=secret')
conn.set_isolation_level(psycopg2.extensions.ISOLATION_LEVEL_AUTOCOMMIT)