#concurrency code explainers

java

import java.time.Duration;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;

A safe recurring heartbeat scheduler in Java

concurrency scheduling thread-safety

Intermediate 6 steps

go

package worker
 
import (
	"fmt"

A graceful worker pool in Go

concurrency goroutines channels

Intermediate 7 steps

ruby

class Throttle
  def initialize(interval)
    @interval = interval
    @mutex = Mutex.new

A thread-safe throttle in Ruby

concurrency rate-limiting mutex

Intermediate 7 steps

ruby

class ThreadSafeCounter
  def initialize(initial = 0)
    @count = initial
    @mutex = Mutex.new

A thread-safe counter with Mutex in Ruby

concurrency mutex thread-safety

Intermediate 6 steps

rust

use std::thread;
 
pub fn parallel_map_reduce<T, M, R, F, G, H>(
    data: &[T],

A parallel map-reduce with scoped threads

concurrency scoped-threads map-reduce

Advanced 8 steps

go

package main
 
import "sync"

Mutex vs RWMutex in Go

concurrency mutex synchronization

Intermediate 6 steps

rust

use std::sync::mpsc;
use std::thread;
use std::time::Duration;

A worker thread driven by Rust channels

concurrency message-passing channels

Intermediate 8 steps