pcdinh

import com.lmax.disruptor.RingBuffer;
import com.lmax.disruptor.dsl.Disruptor;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class BackgroundLogger
{
    private static final int ENTRIES = 64;

pcdinh

#!/usr/bin/env python

import math, os.path, re, json, hyperclient
from os import urandom
from base64 import b32encode
from hashlib import md5
from pprint import pprint

__all__ = 'HyperBayes'

pcdinh

UPDATE pg_database SET datistemplate = FALSE WHERE datname = 'template1';
DROP DATABASE template1;
CREATE DATABASE template1 WITH TEMPLATE = template0 ENCODING = 'UNICODE';
UPDATE pg_database SET datistemplate = TRUE WHERE datname = 'template1';
\c template1
VACUUM FREEZE;
UPDATE pg_database SET datallowconn = FALSE WHERE datname = 'template1';

pcdinh

var http = require('http')
  , request = http.IncomingMessage.prototype;

/**
 * Add a uniform interface for remote address in Node.js
 *
 * @api private
 */

request.__defineGetter__('remote', function remote () {

pcdinh

import gevent
from gevent import monkey, queue

monkey.patch_all()

import urllib2
from time import sleep
import traceback
import logging

pcdinh

import time
from werkzeug.serving import BaseRequestHandler

class MyFancyRequestHandler(BaseRequestHandler):
    """Extend werkzeug request handler to suit our needs."""
    def handle(self):
        self.fancyStarted = time.time()
        rv = super(MyFancyRequestHandler, self).handle()
        return rv

pcdinh

#!/usr/bin/env python
import select
import time
import psycopg2
import psycopg2.extensions
import sys


def get_cursor():
    conn = psycopg2.connect("dbname=pgpubsub")

pcdinh

import redis                                                                    
import binascii                                                                 
import md5                                                                      
                                                                                
                                                                                
s0 = redis.Redis(port=6379)                                                     
s1 = redis.Redis(port=6380)                                                     
s2 = redis.Redis(port=6381)                                                     
s3 = redis.Redis(port=6382)                                                     
                                                                                

pcdinh

from __future__ import with_statement
from kombu import BrokerConnection
from collections import defaultdict
import gevent
from gevent import monkey
monkey.patch_all()

class WorkerHub():
    """
    WorkerHub controls the local mailboxes that the @worker decorator assigns.

pcdinh

import redis
import threading

class Listener(threading.Thread):
    def __init__(self, r, channels):
        threading.Thread.__init__(self)
        self.redis = r
        self.pubsub = self.redis.pubsub()
        self.pubsub.subscribe(channels)