গোরুটিন লিক কী কারণে ঘটে এবং আপনি সেগুলি কীভাবে প্রতিরোধ করবেন?

Question

Accepted Answer

একটি **গোরুটিন লিক** হল একটি গোরুটিন যা কখনও সমাপ্ত হয় না — এটি ব্লক হয়ে থাকে বা চিরকাল চলতে থাকে, মেমোরি খরচ করে (এবং এর রেফারেন্স করা অবজেক্টগুলি জীবিত রাখে) প্রোগ্রামের সারাজীবন জুড়ে। যেহেতু গোরুটিনগুলি শুরু করার জন্য সস্তা, সেগুলি লিক করা সহজ, এবং লিকগুলি নীরবে জমা হতে থাকে যতক্ষণ না সেবা অবনতি হয় বা মেমোরি শেষ হয়ে যায়।

## কারণ ১: কোনও পাঠক/লেখক ছাড়াই চ্যানেলে ব্লক হওয়া

```go
// ❌ LEAK — this goroutine blocks forever waiting to send
func leak() {
    ch := make(chan int)   // unbuffered
    go func() {
        ch <- 42           // blocks forever — NOBODY ever receives
    }()                     // the goroutine is stuck, never exits
    // function returns without reading ch → the goroutine leaks
}
```

একটি চ্যানেল সেন্ড/রিসিভে ব্লক হওয়া একটি গোরুটিন যা কখনও সম্পূর্ণ হয় না সেটি **চিরকাল** অপেক্ষা করবে — এটি কখনও গার্বেজ সংগ্রহ করা হয় না কারণ এটি প্রযুক্তিগতভাবে এখনও "চলছে"।

## কারণ ২: বাতিলকরণ / সম্পন্ন সংকেত নেই

```go
// ❌ LEAK — a goroutine in an infinite loop with no way to stop
func worker(jobs <-chan int) {
    for {
        job := <-jobs      // blocks forever if jobs is never closed and stops sending
        process(job)
    }                       // no exit condition — leaks when no longer needed
}
```

## প্রতিরোধ ১: বাতিলকরণের জন্য context ব্যবহার করুন

```go
// ✅ the goroutine can be told to stop
func worker(ctx context.Context, jobs <-chan int) {
    for {
        select {
        case job := <-jobs:
            process(job)
        case <-ctx.Done():       // cancellation signal → exit cleanly
            return                // the goroutine terminates, no leak
        }
    }
}
// caller: ctx, cancel := context.WithCancel(...); defer cancel()
```

প্রতিটি দীর্ঘ-জীবিত গোরুটিনকে বাতিল করার একটি উপায় দেওয়া (`<-ctx.Done()`) হল প্রাথমিক প্রতিরক্ষা — এটি নিশ্চিত করে যে গোরুটিনগুলি সমাপ্ত হয় যখন তাদের কাজের আর প্রয়োজন নেই।

## প্রতিরোধ ২: বাফার করা চ্যানেল ব্যবহার করুন বা রিসিভার নিশ্চিত করুন

```go
// ✅ ensure a receiver exists, or use a buffered channel so the send doesn't block
ch := make(chan int, 1)   // buffered → the send completes even if no one receives yet
go func() { ch <- 42 }()   // doesn't block
```

## প্রতিরোধ ৩: সর্বদা চ্যানেল বন্ধ করুন / সেগুলি সঠিকভাবে খালি করুন

```go
// ✅ close channels so range loops terminate
go func() {
    defer close(results)    // signal completion → for-range over results ends
    for _, job := range jobs { results <- process(job) }
}()
```

## লিক সনাক্তকরণ

```go
runtime.NumGoroutine()         // monitor the goroutine count — steady growth = leak
import _ "net/http/pprof"      // pprof exposes goroutine stacks (/debug/pprof/goroutine)
// the goleak library asserts no leaked goroutines in tests
```

`runtime.NumGoroutine()` নিরীক্ষণ করা (একটি ক্রমাগত ঊর্ধ্বমুখী গণনা একটি লিক নির্দেশ করে), `pprof` এর মাধ্যমে গোরুটিন ডাম্প পরিদর্শন করা, এবং পরীক্ষায় `goleak` ব্যবহার করা হল প্রধান সনাক্তকরণ সরঞ্জাম।

## এটি কেন গুরুত্বপূর্ণ

গোরুটিন লিক হল উৎপাদন Go সেবাগুলিতে সবচেয়ে সাধারণ এবং সবচেয়ে বিপজ্জনক সমস্যাগুলির মধ্যে একটি।

যেহেতু গোরুটিনগুলি চালু করার জন্য খুবই সস্তা, ডেভেলপাররা সেগুলি অবাধে তৈরি করে — তবে একটি গোরুটিন চিরকালের জন্য ব্লক হওয়া (একটি চ্যানেলে কোনও প্রতিপক্ষ ছাড়াই, বা কোনও বাতিলকরণ ছাড়াই একটি অসীম লুপে) **কখনও সমাপ্ত হয় না এবং কখনও এর মেমোরি মুক্ত করে না** (এটি যা রেফারেন্স করে তার সবকিছু সহ)।

দীর্ঘ-চলমান সেবায়, এই লিকগুলি নীরবে জমা হয়, ধীরে ধীরে মেমোরি খরচ করে যতক্ষণ না সেবা অবনতি হয় বা ক্র্যাশ হয় — এবং সেগুলি সনাক্ত করা কঠিন কারণ কোনও তাৎক্ষণিক ত্রুটি নেই।

কারণগুলি বোঝা (চ্যানেল অপারেশনে ব্লক করা, বাতিলকরণ মিস করা) এবং প্রতিরোধগুলি (**context-ভিত্তিক বাতিলকরণ** প্রাথমিক প্রতিরক্ষা হিসাবে, সঠিক চ্যানেল বন্ধ করা, বাফার করা চ্যানেল, রিসিভার নিশ্চিত করা) নির্ভরযোগ্য সমসাময়িক Go লেখার জন্য অপরিহার্য।

সনাক্তকরণ সরঞ্জামগুলি জানা (`runtime.NumGoroutine`, pprof, goleak) সমান গুরুত্বপূর্ণ।

এটি একটি গুরুত্বপূর্ণ, ঘন ঘন পরীক্ষিত বিষয় যা যারা উৎপাদন-গ্রেড সমসাময়িক Go লিখতে পারে তাদের এবং যারা টেকসই লোডের অধীনে লিক করে এমন কোড লেখে তাদের আলাদা করে।