Bind process to cpu

controller/cmd/manager/BUILD

@@ -5,6 +5,5 @@ go_binary(
   srcs = ["main.go"],
   deps = [
     "//internal/manager",
-    "//pkg/binary",
   ],
 )

controller/internal/conn/BUILD

@@ -0,0 +1,11 @@
+load("@rules_go//go:def.bzl", "go_library")
+
+go_library(
+  name = "conn",
+  srcs = ["unix.go"],
+  deps = [
+    "//pkg/converter",
+  ],
+  importpath = "github.com/moevm/grpc_server/internal/conn",
+  visibility = ["//visibility:public"],
+)

controller/internal/manager/BUILD

@@ -5,6 +5,7 @@ go_library(
   srcs = ["manager.go"],
   deps = [
     "//pkg/converter",
+    "//internal/conn"
   ],
   importpath = "github.com/moevm/grpc_server/internal/manager",
   visibility = ["//visibility:public"],

controller/internal/worker/BUILD

@@ -5,6 +5,7 @@ go_library(
   srcs = ["worker.go"],
   deps = [
     "//pkg/converter",
+    "//internal/conn"
   ],
   importpath = "github.com/moevm/grpc_server/internal/worker",
   visibility = ["//visibility:public"],

docker-compose.yml

@@ -1,11 +1,10 @@
 version: '3.8'
 
 services:
-  hash:
+  worker:
     build: 
       context: .
       dockerfile: Dockerfile.hash
-    container_name: worker
     volumes:
       - ./worker/data:/data 
     working_dir: /data

scripts/start.sh

@@ -0,0 +1,15 @@
+#!/bin/bash
+set -e
+
+CPU_COUNT=$(nproc)
+
+docker-compose up -d --scale worker=$CPU_COUNT
+
+for (( i=0; i<$CPU_COUNT; i++ ))
+do
+  container_id=$(docker-compose ps -a -q worker | sed -n "$((i+1))p")
+  if [ -n "$container_id" ]; then
+    docker update --cpuset-cpus="$i" "$container_id"
+  fi
+done
+