Code Explainers

Code explainers tagged #producer-consumer

import asyncio
import logging
from dataclasses import dataclass

A concurrent batch geocoder in asyncio

asyncio producer-consumer rate-limiting

Advanced 8 steps

java

public class WorkPipeline {
    private final BlockingQueue<Task> queue = new LinkedBlockingQueue<>(1000);
    private static final Task POISON = new Task(-1, null);
    private final ExecutorService consumers = Executors.newFixedThreadPool(4);

A producer-consumer pipeline in Java

concurrency producer-consumer blocking-queue

Intermediate 8 steps