آموزش جاوا مدرن: Stream Gatherers و هم‌روندی مقیاس‌پذیر (Scalable Concurrency) - آخرین آپدیت

سرفصل ها و درس ها

مقدمه Introduction

• نیاز به Stream Gatherers Need For Stream Gatherers

Gathererهای بدون حالت (Stateless) Stateless Gatherers

• اصطلاحات استریم Stream Terminologies

• اجزای Gatherer Gatherer Components

• درخواست ویژه و منابع *** Humble Request & Resource ***

• راه‌اندازی پروژه Project Setup

• نحوه عملکرد Integrator با Upstream How Integrator Works With Upstream

• نحوه عملکرد Integrator با Downstream How Integrator Works With Downstream

• مرور سریع Quick Recap

• پیاده‌سازی Filter Implementing Filter

• Integrator حریص (Greedy) Greedy Integrator

• Gatherer ترتیبی (Sequential) Sequential Gatherer

• پیاده‌سازی FlatMap Implementing FlatMap

• تمرین: اپراتور Take Until [ASSIGNMENT] - Take Until Operator

• پاسخ تمرین: اپراتور Take Until [ASSIGNMENT SOLUTION] - Take Until Operator

• جمع‌بندی Summary

• آزمون Quiz

Gathererهای حالت‌دار (Stateful) Stateful Gatherers

• Initializer (مقداردهنده اولیه) Initializer

• نحوه عملکرد Initializer How Initializer Works

• Gatherer برای مقادیر متمایز (Distinct) Distinct Gatherer

• تمرین: Distinct Recent Gatherer [ASSIGNMENT] - Distinct Recent Gatherer

• Gatherer میانگین متحرک (Moving Average) Moving Average Gatherer

• جمع‌بندی Summary

• آزمون Quiz

Finisher (نهایی‌کننده) Finisher

• نحوه عملکرد Finisher - بخش اول How Finisher Works - Part 1

• نحوه عملکرد Finisher - بخش دوم How Finisher Works - Part 2

• Gatherer مدل Batch Until Batch Until Gatherer

• ساختار داده سلسله‌مراتبی: Expand Gatherer - بخش اول Hierarchical Data Structure - Expand Gatherer - Part 1

• ساختار داده سلسله‌مراتبی: Expand Gatherer - بخش دوم Hierarchical Data Structure - Expand Gatherer - Part 2

• منابع *** Resource ***

• ساختار داده سلسله‌مراتبی: دموی Expand Gatherer Hierarchical Data Structure - Expand Gatherer - Demo

• زنجیره‌سازی Gathererها Chaining Gatherers

• خطای isRejecting در Downstream و راهکار آن Downstream isRejecting - Issue & Workaround

• آزمون Quiz

Gathererهای حالت‌دار با استریم موازی Stateful Gatherers With Parallel Stream

• نیاز به Combiner (ترکیب‌کننده) Need For Combiner

• نحوه عملکرد Combiner How Combiner Works

• چرا SubTaskهای بیشتری داریم؟ Why We Have More SubTasks!

• Gatherer مقدار حداکثری موازی Parallel Max Gatherer

• Gatherer مدل TopN - بخش اول TopN Gatherer - Part 1

• Gatherer مدل TopN - بخش دوم TopN Gatherer - Part 2

• آیا به Parallel Stream نیاز دارید؟ Do You Need Parallel Stream?

• آزمون Quiz

Gathererهای داخلی (Built-in) Built-In Gatherers

• مقایسه Window Fixed و Window Sliding Window Fixed vs Window Sliding

• عملیات Fold Fold

• عملیات Scan Scan

• Map Concurrent (نقشه‌برداری هم‌زمان) Map Concurrent

• تفاوت Parallel و Map Concurrent در نحوه عملکرد Parallel vs Map Concurrent - How They Work

• ترتیب و مشکلات احتمالی در Map Concurrent Map Concurrent - Ordering & Potential Issues

• جمع‌بندی Summary

الگوهای هم‌روندی با Virtual Threads و Stream Gatherers Concurrency Patterns With Virtual Threads & Stream Gatherers

• سرویس‌های خارجی *** External Services ***

• بررسی سرویس‌های خارجی External Services

• کلاینت سرویس خارجی External Service Client

• پیاده‌سازی Map Concurrent Map Concurrent

• پیاده‌سازی Execute Concurrent Gatherer - بخش اول Execute Concurrent Gatherer Implementation - Part 1

• پیاده‌سازی Execute Concurrent Gatherer - بخش دوم Execute Concurrent Gatherer Implementation - Part 2

• پیاده‌سازی Execute Concurrent Gatherer - بخش سوم Execute Concurrent Gatherer Implementation - Part 3

• دموی Execute Concurrent Gatherer Execute Concurrent Gatherer - Demo

• محدود کردن درخواست‌های در جریان (In-Flight) Limiting In-Flight Requests

• پیاده‌سازی Delay Error Gatherer - بخش اول Delay Error Gatherer Implementation - Part 1

• پیاده‌سازی Delay Error Gatherer - بخش دوم Delay Error Gatherer Implementation - Part 2

• دموی Delay Error Gatherer Delay Error Gatherer - Demo

• مدیریت خطا در ExecutorService با برنامه‌نویسی داده-محور ExecutorService: Error Handling Using Data Oriented Programming

• هم‌روندی تو در تو: بیان مسئله Nested Concurrency - Problem Statement

• هم‌روندی تو در تو: Aggregate Concurrent Gatherer - بخش اول [Nested Concurrency] - Aggregate Concurrent Gatherer - Part 1

• هم‌روندی تو در تو: Aggregate Concurrent Gatherer - بخش دوم [Nested Concurrency] - Aggregate Concurrent Gatherer - Part 2

• هم‌روندی تو در تو: شفاف‌سازی حداکثر هم‌روندی [Nested Concurrency] - Max Concurrency Clarification

• در مورد SubTaskهای بیشتر چه می‌گوییم؟ What About More SubTasks?

• پیاده‌سازی SubTask Executor SubTask Executor - Implementation

• دموی SubTask Executor SubTask Executor - Demo

• الگوی Timeout و مشکلات احتمالی Timeout Pattern & Potential Issues

• محدودیت‌های Blocking Integrator Limitations Of Blocking Integrator

پردازش I/O عظیم با Virtual Threads و Stream Gatherers Massive I/O With Virtual Threads & Stream Gatherers

• بحث پیرامون نیازمندی‌ها Requirements Discussion

• هدف پروژه Project Goal

• منابع *** Resource ***

• راه‌اندازی پروژه Project Setup

• کلاینت داده‌های جغرافیایی (Geo Data) Geo Data Client

• پیکربندی اپلیکیشن Application Configuration

• راه‌اندازی سرویس Geo Crawler Geo Crawler Service Setup

• مشکل نتایج میانی Intermediate Results Issue

• پیاده‌سازی سرویس Geo Crawler Geo Crawler Service Implementation

• دموی Geo Crawler Geo Crawler Demo

• رفع خطای Connection Reset Connection Reset Error - Issue Fix

• جمع‌بندی Summary

گام‌های بعدی چیست؟ Whats Next?

• گام‌های بعدی چیست؟ Whats Next?