codesnips

throughput

java 
package com.example.orders;

public final class Order {

    public static final Order POISON_PILL = new Order(-1L, 0.0);

Producer/Consumer Order Processing With a Bounded BlockingQueue in Java

java concurrency blockingqueue
by codesnips 3 tabs
rust 
#[derive(Debug, Clone)]
pub struct Order {
    pub id: u64,
    pub amount_cents: i64,
    pub currency: [u8; 3],
}

Partition a Slice of Orders into Shards for Parallel Processing with Rayon

rust rayon parallelism
by codesnips 2 tabs
rust 
use sqlx::PgPool;
use std::time::Duration;
use tokio::sync::mpsc;

#[derive(Debug, Clone)]
pub struct MetricPoint {

Batching Database Writes in Rust with a Size- and Interval-Triggered Flush Buffer

rust tokio sqlx
by codesnips 3 tabs