yanfenglee

import matplotlib.pyplot as plt
from matplotlib.animation import FuncAnimation
import polars as pl
import matplotlib as mpl
import requests
from datetime import datetime, timedelta
import enum
import time
from playsound import playsound
import threading

yanfenglee

import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicLong;

class QueueCachedTaskRunner<T> implements Runnable {
    private final BlockingQueue<T> queue;
    private ExecutorService executor;
    private AtomicLong taskCount = new AtomicLong();

    QueueCachedTaskRunner(int queueSize, int numThread) {
        this.queue = new LinkedBlockingQueue<>(queueSize);

yanfenglee

/*
 * stupid congestion control
 *
 */

#include <linux/module.h>
#include <net/tcp.h>

static int fixed_cwnd __read_mostly = 1000;
module_param(fixed_cwnd, int, 0644);

yanfenglee

(defn get-hash [type data]
(.digest (java.security.MessageDigest/getInstance type) (.getBytes data) ))
 
(defn sha1-hash [data]
 (get-hash "sha1" data))
 
(defn get-hash-str [data-bytes]
  (apply str 
  (map 
		#(.substring