| package main | |
| import ( | |
| "encoding/base64" | |
| "fmt" | |
| "github.com/VirgilSecurity/virgil-sdk-go" | |
| "io/ioutil" | |
| ) | |
| func main() { |
| class Cell | |
| attr_accessor :alive | |
| attr_accessor :coordinates | |
| attr_accessor :neighbours | |
| attr_accessor :live_neighbours | |
| def initialize(live_cell_ratio) | |
| @alive = ([true] + Array.new(live_cell_ratio, false)).sample | |
| @coordinates = [] | |
| @neighbours = [] |
| def highlight_oid(oid) | |
| str = oid.to_s | |
| rgx = /(?<ts>\w{8})(?<machine>\w{6})(?<process>\w{4})(?<counter>\w{6})/ | |
| m = str.match(rgx) | |
| require 'colorize' | |
| print m[:ts].red | |
| print m[:machine].yellow | |
| print m[:process].light_magenta | |
| print m[:counter].green | |
| puts |
| def ts_to_oid(timestamp) | |
| unixtime = timestamp.to_i.to_s(16) | |
| BSON::ObjectId.from_string(unixtime + '0' * 16) | |
| end |
| module Enumerable | |
| def count_by(&block) | |
| Hash[group_by(&block).map { |key,vals| [key, vals.size] }] | |
| end | |
| end |
| hello world! |
| class Proc | |
| def and(other_proc) | |
| ->(*args) { call(*args) && other_proc.call(*args) } | |
| end | |
| end | |
| def word_or_number(n) | |
| div3 = ->(x) { x.modulo(3).zero? } | |
| div5 = ->(x) { x.modulo(5).zero? } | |
| require 'openssl' | |
| require 'jwt' | |
| require 'awesome_print' | |
| rsa_private = OpenSSL::PKey::RSA.generate 2048 | |
| rsa_public = rsa_private.public_key | |
| payload = { | |
| 'data' => 'test', | |
| 'projects.quote.request' => true, |
| RUN echo "https://mirror.yandex.ru/mirrors/alpine/v3.7/main" > /etc/apk/repositories \ | |
| && echo "https://mirror.yandex.ru/mirrors/alpine/v3.7/community" >> /etc/apk/repositories \ | |
| && echo "https://mirror.yandex.ru/mirrors/alpine/v3.5/main" >> /etc/apk/repositories \ |
A running example of the code from:
This gist creates a working example from blog post, and a alternate example using simple worker pool.
TLDR: if you want simple and controlled concurrency use a worker pool.