Dev Perfects

Forwarded from DevTwitter | توییت برنامه نویسی

الگوهای مهم Concurrency توی Golang
گاهی وقتا توی Go، کار کردن با concurrency فقط goroutine و channel نیست، یه سری الگو هست که وقتی یاد گرفتم واقعا دیدم کار رو راحت‌تر می‌کنن. مثلا یکی از اینا fan-out/fan-in هست. یعنی فرض کن چند تا goroutine داری که همزمان دارن یه سری داده رو پردازش می‌کنن (این میشه fan-out) و بعد همه‌شون خروجیشون رو میریزن توی یه کانال واحد تا جمع بشه (fan-in). من معمولا اینو وقتی استفاده می‌کنم که یه عالمه فایل یا دیتا دارم که میشه به صورت موازی روشون کار کرد. یه بار برای پردازش لاگ‌ها ازش استفاده کردم، هر worker یه بخش لاگ رو می‌خوند و پردازش می‌کرد و در نهایت همه‌ی نتایج توی یه جا جمع می‌شد.
یه الگوی دیگه که خیلی پرکاربرده worker pool ـه. به جای اینکه برای هر کاری یه goroutine جدا درست کنم، میام یه تعداد ثابت worker درست می‌کنم، مثلا ۵ تا، و همه‌ی کارها رو میریزم توی یه صف. workerها یکی‌یکی برمی‌دارن و انجام میدن. اینجوری هم منابع مصرف نمی‌شن هم قابل مدیریت‌تره. مثلا وقتی می‌خواستم ایمیل انبوه بفرستم، با worker pool خیلی راحت مدیریت کردم که سیستم منفجر نشه.
یه چیزی که همیشه باید حواسم باشه، محدود کردن هم‌زمانی یا همون bounded concurrency هست. مثلا وقتی می‌خوام به یه API خارجی درخواست بزنم، اگه بذارم ۱۰۰ تا goroutine همزمان بزنن، خیلی راحت اون سرویس منو بلاک می‌کنه یا خودم دچار timeout می‌شم. اینجاست که با یه کانال ساده یا semaphore جلوی تعداد درخواست‌ها رو می‌گیرم، مثلا نهایتا ۱۰ تا همزمان.
حالا مشکل بعدی backpressure ـه. این زمانی اتفاق میفته که producer سریع‌تر از consumer کار می‌کنه. مثلا تصور کن داری رویدادها رو از یه سیستم دیگه می‌گیری ولی پردازشت کندتره. اگه هیچ محدودیتی نباشه، حافظه‌ت پر میشه. من معمولا با کانال‌های buffer‌دار اینو مدیریت می‌کنم؛ وقتی بافر پر میشه producer گیر می‌کنه تا consumer کمی جلو بیفته. یه بار اینو توی سیستم لاگینگ پیاده کردم، به جای اینکه همه‌ی لاگ‌ها رو بدون کنترل بخوره، با backpressure سرعت متعادل شد.
یه چیز مهم دیگه cancellation ـه. بارها پیش اومده یه کاری رو استارت زدم ولی دیگه نیاز نبوده ادامه پیدا کنه. مثلا یه درخواست HTTP طولانی بود و کاربر صفحه رو بست. با context خیلی راحت میشه اینو مدیریت کرد، وقتی سیگنال cancel بیاد، همه‌ی goroutineهای مربوطه متوقف می‌شن. این باعث میشه منابع الکی مصرف نشن.
در نهایت هم timeout. خیلی وقتا نمی‌خوای یه عملیات تا ابد ادامه پیدا کنه. مثلا وقتی به یه سرویس بیرونی وصل میشی، میگی اگه بیشتر از ۲ ثانیه طول کشید، دیگه مهم نیست جواب چی بود، تمومش کن. این کار نه تنها سیستم رو responsive نگه می‌داره، بلکه از گیر کردن کل برنامه جلوگیری می‌کنه.

@DevTwitter | <Mohammad Salehi/>

8 views15:49