zhangmingkai4315

import argparse
import random 
import math
import queue
import time
import logging
import threading
import dns.resolver
import datetime

zhangmingkai4315

package slider

import "time"

type Window struct {
	start int64
	count int64
}

func (window *Window) Start() time.Time{

zhangmingkai4315

from selectors import DefaultSelector, EVENT_READ, EVENT_WRITE
import socket
import time
selector = DefaultSelector()
jobs = 0


class Future:
    def __init__(self):
        self.callback = None

zhangmingkai4315

// An algorithm that randomly chooses an item from this stream such that 
// each item is equally likely to be selected.
// AKA : Reservoir Sampling 

package main

import (
	"math"
	"math/rand"
	"sync"

zhangmingkai4315

package main

import (
	"encoding/json"
	"flag"
	"fmt"
	"log"
	"net/http"
)

zhangmingkai4315

from multiprocessing import Process
import threading
import queue
import time
import dns.resolver
from queue import Queue

TERM_SIGNAL = "TERM"
ServerListFile = "./example.txt"
MaxWorker = 10

zhangmingkai4315

# -*- coding: utf-8 -*-

pattern = "acabacacd"
text = "acaacabacabacacda"


def create_prefix_table(p):
    size = len(p)
    table = [0]*size

zhangmingkai4315

import time
from threading import Thread
from queue import Queue

# class style generator
class Ticker():
    def __init__(self, second):
        self.sleep = second
    def __iter__(self):

zhangmingkai4315

import argparse
import random 
import math
import queue
import time
import logging
import threading
import dns.resolver
import datetime

zhangmingkai4315

class Queue:
    def __init__(self):
        self.queue = []

    def enqueue(self, item):
        self.queue.append(item)

    def dequeue(self):
        if self.size() < 1:
            return None