Rueian rueian

rueian / nyu_depth_v2.py

Last active December 19, 2022 04:40

	import torch
	from torch import nn
	from torch.nn import functional as F
	from torchvision import transforms
	import pytorch_lightning as pl


	class Block(nn.Module):
	def __init__(self, in_ch, out_ch):
	super().__init__()

rueian / redis_benchmark.go

Last active December 17, 2022 04:24

	package allocs

	import (
	"context"
	"testing"
	"time"

	"github.com/go-redis/redis/v9" // v9-rc2
	"github.com/rueian/rueidis" // v0.0.90
	)

rueian / ray_heterogeneous_actor_pool.py

Last active August 23, 2022 14:44

	import ray
	import time
	from dataclasses import dataclass
	from heapq import heappush, heappop

	@dataclass
	class Meta:
	max: int
	rtt: float = 10
	size: int = 1

rueian / Dockerfile.pytorchray

Created August 3, 2022 16:46

	# syntax=docker/dockerfile:experimental

	FROM nvidia/cuda:11.4.0-cudnn8-devel-ubuntu20.04

	ENV PATH /usr/local/bin:$PATH

	# http://bugs.python.org/issue19846
	# > At the moment, setting "LANG=C" on a Linux system fundamentally breaks Python 3, and that's not OK.
	ENV LANG C.UTF-8
	ENV DEBIAN_FRONTEND noninteractive

rueian / gist:5f568007cdb5ee3b3fe42ad42192bc97

Created June 22, 2022 00:11

	import os
	import sys
	import ssl
	import json
	import socket
	import asyncio

	import util
	async def proxy(node_id):
	dir = os.path.join(os.getcwd(), '.ray-delegate')

rueian / gist:40425991ccea03f6bd40067931d72097

Created June 22, 2022 00:11

	import asyncio
	import os
	import ssl
	import json
	import secrets

	import util
	from ray.util import get_node_ip_address

	async def handle_echo(reader, writer):

rueian / rueidisom.go

Last active May 27, 2022 09:28

rueian / benchmark_cond2.sh

Last active February 20, 2022 15:04

	▶ go test -bench=BenchmarkCond ./ring_test.go
	goos: darwin
	goarch: arm64
	BenchmarkCond/Chan-size-64-parallelism-01-10 5995210 203.6 ns/op
	BenchmarkCond/Ring-size-64-parallelism-01-10 7178178 162.0 ns/op
	BenchmarkCond/Chan-size-64-parallelism-08-10 3785736 314.9 ns/op
	BenchmarkCond/Ring-size-64-parallelism-08-10 5421237 204.3 ns/op
	BenchmarkCond/Chan-size-64-parallelism-64-10 3847623 309.3 ns/op
	BenchmarkCond/Ring-size-64-parallelism-64-10 5169406 235.1 ns/op
	PASS

rueian / writing.go

Last active February 20, 2022 13:42

	var waits = int32(0)
	var sleep = int32(0)
	var cond = sync.Cond{L: (*emptyLock)(nil)}

	func makeRequest(req request, queue *ring) (resp response) {
	waits := atomic.AddInt32(&waits, 1)
	ch := queue.EnqueueRequest(queue)
	if waits == 1 {
	for atomic.LoadInt32(&sleep) != 0 {
	cond.Broadcast()

rueian / benchmark_cond_test.go

Last active February 20, 2022 15:02