1. সিঙ্ক্রোনাইজেশন মেকানিজমের ভূমিকা
কনকারেন্ট প্রোগ্রামিং এ, যখন একাধিক গোরুটিন শেয়ার রিসোর্স, রিসোর্সগুলির কেবল একটি গোরুটিন মাএ অ্যাক্সেস করতে দিতে হয় যাতে রেস কন্ডিশন এর অবস্থা হতে না পারে। এটা সিঙ্ক্রোনাইজেশন মেকানিজমের ব্যবহারের প্রয়োজন। সিঙ্ক্রোনাইজেশন মেকানিজমগুলি বিভিন্ন গোরুটিনগুলির শেয়ারড রিসোর্সের অ্যাক্সেস অর্ডার সমন্বয় করতে পারে, কনকারেন্ট এনভায়রনমেন্টে ডেটা কনজিস্টেন্সি এবং স্টেট সিঙ্ক্রোনাইজেশন নিশ্চিত করতে।
গো ভাষা একটি প্রস্তুত সিঙ্ক্রোনাইজেশন মেকানিজম সরবরাহ করে, যার মধ্যে মিউটেক্স (sync.Mutex), রিড-ওয়ারাইট মিউটেক্স (sync.RWMutex), চ্যানেল, ওয়েটগ্রুপ, আটোমিক ফাংশন (আটোমিক প্যাকেজ) এবং কন্ডিশন ভ্যারিয়েবল (sync.Cond) রয়েছে।
2. সিঙ্ক্রোনাইজেশন প্রাইমিটিভ
2.1 মিউটেক্স (sync.Mutex)
2.1.1 মিউটেক্সের ধারণা এবং ভূমিকা
মিউটেক্স হল একটি সিঙ্ক্রোনাইজেশন মেকানিজম যা একটি দিয়ে একাধিক গোরুটিন দিয়ে শেয়ারড রিসোর্সের নিরাপত্তা অভিনয়নের দ্বারা নিরাপত্তা নিশ্চিত করে। মিউটেক্স Lock
এবং Unlock
মেথড দ্বারা সিঙ্ক্রোনাইজেশন অর্জন করে। Lock
মেথডটি কল করার জন্য লক আদান প্রদান করবে এবং এই পয়েন্টে, অন্যান্য গোরুটিনগুলি যারা লক অর্জন করতে চেষ্টা করছে তারা অপেক্ষা করবে। Unlock
কল করার মাধ্যমে লক মুক্তি দেয়, অন্যান্য প্রতীক্ষারত গোরুটিনগুলিকে তা অর্জন করার অনুমতি দেয়।
var mu sync.Mutex
func criticalSection() {
// লক অর্জন করুন যাতে আমি একটি স্বতন্ত্রভাবে রিসোর্সে অ্যাক্সেস করতে পারি
mu.Lock()
// এখানে শেয়ারড রিসোর্সে অ্যাক্সেস করুন
// ...
// অন্যান্য গোরুটিনগুলিকে লক অর্জন করার অনুমতি দিতে লক মুক্তি দিতে
mu.Unlock()
}
2.1.2 মিউটেক্সের ব্যবহার
ধরা যাক, আমাদের একটি গ্লোবাল কাউন্টার রাখতে হবে, এবং এর মানটি বাড়াতে বেশি গোরুটিনগুলি প্রয়োজন। মিউটেক্স ব্যবহার করা যাবে কাউন্টারটির সঠিকতা নিশ্চিত করতে
var (
mu sync.Mutex
counter int
)
func increment() {
mu.Lock() // কাউন্টারটি সংশোধন করার আগে লক অর্জন করুন
counter++ // কাউন্টারটি সুরক্ষাপূর্বক বাড়ান
mu.Unlock() // অপারেশন শেষে লক মুক্তি
}
func main() {
for i := 0; i < 10; i++ {
go increment() // কাউন্টারের মান বাড়াতে একাধিক গোরুটিগুলি শুরু করুন
}
// কিছু সময় অপেক্ষা করুন (বাস্তবায়, আপনার সব গোরুটিগুলিকে সমাপ্ত হওয়ার জন্য আপনার অনুমতি বা অন্যান্য পদ্ধতিগুলিকে অব্যাহত রাস্তাপাই accept করতে হবে)
time.Sleep(1 * time.Second)
fmt.Println(counter) // কাউন্টারের মান আউটপুট করুন
}
2.2 রিড-ওয়ারাইট মিউটেক্স (sync.RWMutex)
2.2.1 রিড-ওয়ারাইট মিউটেক্সের ধারণা
আরডব্লিউমিউটেক্স একটি বিশেষ প্রকারের লক যা মানের চেয়ে বেশি প্রথমদিকে একাধিক গোরুটির ইউনেক্সরের অনুমতি দেয়, যদিও রাইট অপারেশনগুলি এক্সক্লুসিভ। মিউটেক্সগুলির তুলনায়, রিড-ওয়ারাইট লকগুলি মাল্টি-রিডার সিনেরিওস মৌলিক গল্পে পারফর্মেন্স উন্নতি করতে পারে। এর চারটি মেথড রয়েছে: RLock
, RUnlock
রিড অপারেশনের জন্য লক এবং আনলক এবং Lock
, Unlock
রাইট অপারেশনের জন্য লক এবং আনলক।
2.2.2 রিড-ওয়ারাইট মিউটেক্সের ব্যবহার
একটি ডাটাবেস অ্যাপ্লিকেশানে, রিড অপারেশনগুলি লিখতের অপারেশনগুলির চেয়ে অনেক বেশি হতে পারে। একটি রিড-ওয়ারাইট লক পারফরমিয়ন্স উন্নতি প্রদান করে কারণ এটি বেশি পড়বতির অবস্থানে একাধিক গোরুটিগুলি প্রথমদিকে পড়বতি পরিস্থিতিগুলি।
var (
rwMu sync.RWMutex
data int
)
func readData() int {
rwMu.RLock() // পরবর্তী রিড অপারেশনের জন্য রিড লক অর্জন করুন
defer rwMu.RUnlock() // ডিফার ব্যবহার করে লক মুক্তি নিশ্চিত করুন
return data // সুরক্ষিতভাবে ডেটা পড়ুন
}
func writeData(newValue int) {
rwMu.Lock() // লিখিত অপারেশনের জন্য লক অর্জন করুন, এই সময়ে অন্যান্য রিড বা লেখা অপারেশনগুলি প্রতিরোধ করতে
data = newValue // নতুন মান সুরক্ষাপূর্বক লিখুন
rwMu.Unlock() // লেখার পরে আনলক করুন
}
func main() {
go writeData(42) // একটি গোরুটিন শুরু করুন যাতে লেখার অপারেশন সম্পাদন করুন
fmt.Println(readData()) // মেইন গোরুটিন পড়ানোর অপারেশন সম্পাদন করে
// সমস্ত গোরুটিগুলি সমাপ্ত হওয়ার জন্য WaitGroup বা অন্যান্য সিঙ্ক্রোনাইজেশন উপায় ব্যবহার করুন
}
উপরের উদাহরণে, একাধিক রিডার এক্সিকিউট কেরো পড়ানো যায় readData
ফাংশনের মাধ্যমে, তবে writeData
পুলিশ করা writeData
এক্সিকিউট করা লেখা লেখার প্রতিরোধ। এই মেকানিজমটি বেশি প্রথিবি অবস্থায় পারফরমেন্স সুবিধা প্রদান করে।
2.3 কন্ডিশনাল ভেরিয়েবল (sync.Cond
)
2.3.1 শর্তমুলক ভেরিয়েবলের ধারণা
Go ভাষার সিঙ্ক্রোনাইজেশন মেকানিজমে, শর্তমুলক ভেরিয়েবল একটি সিঙ্ক্রোনাইজেশন প্রাইমিটিভ হিসেবে কিছু শর্ত পরিবর্তনের জন্য অপেক্ষা করার বা নোটিফাই করার জন্য ব্যবহৃত হয়। শর্তমুলক ভেরিয়েবল সর্বদা একটি মিউটেক্স (sync.Mutex
) সহ ব্যবহার করা হয়, যা নিজেই শর্তটির নিরাপত্তাকে রক্ষা করার জন্য ব্যবহৃত হয়।
শর্তমুলক ভেরিয়েবলের ধারণা অপারেটিং সিস্টেম ডোমেইন থেকে আসা, যা একটি গোরুটিনের গ্রুপকে একটি নির্দিষ্ট শর্ত পূরণের জন্য অপেক্ষা করার অনুমতি দেয়। অধিক নির্দেশিতভাবে, একটি গোরুটিন যখন নির্দিষ্ট শর্ত পূরণের জন্য অপেক্ষা করছে, এবং একটি অন্য গোরুটিন শর্তমুলক ভেরিয়েবল ব্যবহার করে শর্তটি পরিবর্তন করে অন্য গোরুটিনকে সচেতন করতে পারে।
গো মান মান লাইব্রেরিতে, শর্তমুলক ভেরিয়েবল গুলি sync.Cond
টাইপে প্রদান করা হয়, এবং এর প্রধান মেথডগুলি নিম্নলিখিতঃ
-
Wait
: এই মেথডকে কল করা হলে ধারণ মুক্ত করা হবে এবং ব্লক হবে যতক্ষণ পরের একটি গোরুটি এই নির্দিষ্ট শর্তমুলক ভেরিয়েবলেSignal
বাBroadcast
কল করে তা উঠাতে, পরে এটি আবার লক অর্জন করার চেষ্টা করবে। -
Signal
: এই শর্তমুলক ভেরিয়েবলের জন্য অপেক্ষা করা একটি গোরুটিকে উঠিয়ে দেয়। যদি কোনো গোরুটি অপেক্ষা করছে না হোক, তাহলে এই মেথডটি কল করলে কোনো প্রভাব পড়বে না। -
Broadcast
: এই মেথডটি কল করা হলে এই শর্তমুলক ভেরিয়েবলের জন্য অপেক্ষা করা সব গোরুটিকে উঠিয়ে দেয়।
শর্তমুলক ভেরিয়েবলগুলি কোপি করা উচিত না, তাই সাধারণত এগুলি একটি নির্দিষ্ট স্ট্রাক্চারের পয়েন্টার ফিল্ড হিসেবে ব্যবহার করা হয়।
2.4.2 WaitGroup এর ব্যবহারের কার্যক।
নিচে WaitGroup
এর ব্যবহারের একটি উদাহরণ দেওয়া হলঃ
package main
import (
"fmt"
"sync"
"time"
)
func worker(id int, wg *sync.WaitGroup) {
defer wg.Done() // সমাপ্তি ঘোষণা করতে WaitGroup এ দৃষ্টি নির্দেশ দিয়ে
fmt.Printf("Worker %d starting\n", id)
time.Sleep(time.Second) // সময়-অপসারণ অনুকরণ করতে
fmt.Printf("Worker %d done\n", id)
}
func main() {
var wg sync.WaitGroup
for i := 1; i <= 5; i++ {
wg.Add(1) // গোরুটিন চালু হওয়ার আগে গণনা বাড়ানো
go worker(i, &wg)
}
wg.Wait() // সমস্ত ওয়ার্কার গোরুটিন শেষ করার জন্য অপেক্ষা করুন
fmt.Println("All workers done")
}
এই উদাহরণে, worker
ফাংশন কোনো কাজের প্রশিক্ষণ সম্পাদন সিমুলেট করে। মূল ফাংশনে, আমরা পাঁচটি worker
গোরুটিন চালু করি। প্রতিটি গোরুটিন চালু হওয়ার আগে, আমরা wg.Add(1)
কল করে WaitGroup
এ নতুন কাজ সম্পাদিত হচ্ছে এই বিষয়ে অবহিত করতে। যেটুকু প্রতিটি ওয়ার্কার ফাংশন শেষ হয়, তা defer wg.Done()
কল করে WaitGroup
এ মন্তব্য করে যে কাজ শেষ হয়ে গেছে। সব গোরুটিন চালু হওয়ার পরে, মূল ফাংশন wg.Wait()
এ ব্লক করে যাওয়ার জন্য, যা নানা ওয়ার্কারদের সম্পর্কে প্রতিবেদন করা হয়।
2.5 Atomic Operations (sync/atomic
)
2.5.1 Atomic Operations এর ধারণা।
পরম ক্রিয়া গতিসম্পন্ন প্রোগ্রামিংতে অপ্রতক্ষণ বৈঠকহীন সম্পাদনাডি বুঝায়। এটা অন্য কোনো অপারেশন অভিপ্রেত বা বাধিত নয় সম্পাদনার সময়। একাধিক goroutines এর জন্য, পরম ক্রিয়া ব্যবহারের মাধ্যমে, বিনা তলব, তলব বিনা তলবের তথ্য সুরক্ষিত রাখা এবং অবস্থা সমকক্ষতা নিশ্চিত হবে, কারণ পরম ক্রিয়ার সম্পাদনাই নিজেই সম্পূর্ণা পারি।
Go ভাষায়, sync/atomic
প্যাকেজটি নিম্ন-স্তরের পরম মেমোরি অপারেশন সরবরাহ করে। int32
, int64
, uint32
, uint64
, uintptr
, এবং pointer
সহ সাধারণ ডাটা প্রকারের উদাহরণে, sync/atomic
প্যাকেজের মেথডগুলো ব্যবহারে সুরক্ষিত সম্পাদনার জন্য ব্যবহার আছে। পরম ক্রিয়ার গুরুত্ব শুধু অন্যান্য সম্পর্কিত প্রাথমিকাগুলি (লক এবং শর্ত চেচিং প্রায়শই বেশি করে) তৈরি করার জন্য এবং সাধারণভাবে লকিং পদক্ষেপগুলির তুলনায় কার্যকরী হতে তাও বেশিি সম্ভাবনা থাকে।
2.5.2 Atomic Operations এর ব্যবহারের প্রাকৃতিক ব্যবহার কার্য।
একটি ঘটনা নিয়ে ধারণা করুন যেখানে আমাদেরকে ওয়েব সাইটে পরবর্তী অতিথির সতর্ক সংখ্যা ট্র্যাক করতে হবে। সামান্য গণনা ভেরিয়েবল ব্যবহার করে আমরা সোজা সম্বন্ধে চিন্তা করতে পারি, যেটি দর্শন আস্মীয়ে বর্ধা- মিতি লেখা হবে এবং অতিথি বিরক্তি প্রবেশ বিচ্ছিন্ন হবে। তবে, বৈঠকসহিত এই উপায়ে তথ্যের দ্রুত দর্শনে দুর্ঘটনা ঘটাব। এ কারণে, আমরা কাউন্টারকে নিরাপদভাবে পরিবর্তন করতে sync/atomic
প্যাকেজ ব্যবহার করতে পারি।
package main
import (
"fmt"
"sync"
"sync/atomic"
"time"
)
var visitorCount int32
func incrementVisitorCount() {
atomic.AddInt32(&visitorCount, 1)
}
func decrementVisitorCount() {
atomic.AddInt32(&visitorCount, -1)
}
func main() {
var wg sync.WaitGroup
for i := 0; i < 100; i++ {
wg.Add(1)
go func() {
incrementVisitorCount()
time.Sleep(time.Second) // পরিদর্শকের পরিদর্শনের সময়
decrementVisitorCount()
wg.Done()
}()
}
wg.Wait()
fmt.Printf("Current visitor count: %d\n", visitorCount)
}
এই উদাহরণে, আমরা ১০০ গোরুটিন সৃষ্টি করে পরিদর্শকের প্রবেশ এবং প্রস্থানের সমূহ সিমুলেট করি। atomic.AddInt32()
ফাংশন ব্যবহার করে, আমরা নিশ্চিতকরণ করি যে কাউন্টারের বৃদ্ধি এবং ক্মইশ্ডেন্টসু হবে, সুতরাং অধিক গন্থ পরিদর্শনে, বিনা তাথ্যের সমকক্ষতার একইত্ব সম্পর্কিতও হয়েছে।
2.6 চ্যানেল এর সিঙ্ক্রোনাইজ়েশন ব্যৱস্থা
2.6.1 চ্যানেলের সংক্রিয়তা বৈশিষ্ট্য।
চ্যানেল হল গোরুটিরাইটন এর মধ্যে জানা কাটিকুলারলুনেভেল কমিয়ুনিকেশাটে এর বোকাউইয়ট দিতে পারে। একটি চ্যানেল দিয়ে তথ্য পাঠানো অ্যাবিল হয় এবং প্রাপ্ত অবস্থা থাকা বাদে কোনো গোরুটিং পর্ত্যাপ্ত হয়। যদি একটি গোরুটাও তথ্য পাঠান চেষ্টা করে এবং চ্যানেলটি তথ্য দেয়নি তাহলে সে ডোটা রিসিভ আইটেময়েনোটিাাপডটয়ে নিতে করবে। এটা চ্যানেলগুলি খুবই নিজেশ কর্জেয়ায় হযাায।
2.6.2 চ্যানেল সঙ্গে সিঙ্ক্রোনাইজেশনের ব্যবহার
ধরা যাক, আমাদের একটি কাজ করতে হবে যা একাধিক গোরুটিন দ্বারা সম্পাদন করতে হবে, প্রতিটি সাবটাস্কের সাথে, এবং তারপর আমাদের সব সাবটাস্কের ফলাফলগুলি সংগ্রহ করতে হবে। আমরা সব গোরুটিন শেষ করার জন্য একটি চ্যানেল ব্যবহার করতে পারি।
package main
import (
"fmt"
"sync"
)
func worker(id int, wg *sync.WaitGroup, resultChan chan<- int) {
defer wg.Done()
// কিছু কাজ করুন...
fmt.Printf("ওয়ার্কার %d শুরু\n", id)
// ধারাবাাহিকভাবে বিশ্বাস করা হয় যে সাবটাস্ক ফলাফলটি ওয়ার্কারের আইডি
resultChan <- id
fmt.Printf("ওয়ার্কার %d শেষ\n", id)
}
func main() {
var wg sync.WaitGroup
numWorkers := 5
resultChan := make(chan int, numWorkers)
for i := 0; i < numWorkers; i++ {
wg.Add(1)
go worker(i, &wg, resultChan)
}
go func() {
wg.Wait()
close(resultChan)
}()
// সমস্ত ফলাফল সংগ্রহ করুন
for result := range resultChan {
fmt.Printf("ফলাফল পেয়েছি: %d\n", result)
}
}
এই উদাহরণে, আমরা ৫টি গোরুটিন চালু করে কাজ করার জন্য প্রারম্ভ করি এবং resultChan
চ্যানেল দ্বারা ফলাফল সংগ্রহ করি। মূখ্য গোরুটিন একটি পৃথক গোরুটিনে সব কাজ শেষ হওয়ার জন্য অপেক্ষা করে এবং তারপর ফলাফল চ্যানেলটি বন্ধ করে। পরবর্তীতে, মূখ্য গোরুটিন ফলাফল চ্যানেলটি চালু করে, সব গোরুটিনের ফলাফল সংগ্রহ করে এবং ছাপে।
2.7 একবারের কাজ (sync.Once
)
sync.Once
হল একটি সিঙ্ক্রোনাইজেশন প্রাথমিকতা যা প্রোগ্রামের বেশিরভাগ অবধি শুধুমাত্র একবার কাজ করার নিশ্চিত করে। sync.Once
এর একটি প্রশিষ্ট ব্যবহার হল একটি সিংগেলটন অবজেক্ট এর আরম্ভণ বা দ্বারায়ণের জন্য বা দলিল আবশ্যক স্থিতিতে ব্যবহার করা। এই Do
ফাংশনের নামে হল, যা নিরাপদের নিরাপদ দক্ষতা এবং বাতিন্য প্রদর্শি পাশা নিশ্চিত করা
sync.Once
পুনরাবৃত্তি নিয়ন্ত্রণ ও ব্যাপকতার সমস্যাগুলি অপসারণ করে, পুনরায় বিশিষ্টু আরম্ভণের কারণের মূল্যায়ন সমস্যা নিয়ে চিন্তা৷
sync.Once
এর ব্যবহার প্রদর্শিত করার জন্য একটি সাধারণ প্রদর্শন৷:
package main
import (
"fmt"
"sync"
)
var once sync.Once
var instance *Singleton
type Singleton struct{}
func Instance() *Singleton {
once.Do(func() {
fmt.Println("এখন একক মূল বানাও আছি।")
instance = &Singleton{}
})
return instance
}
func main() {
for i := 0; i < 10; i++ {
go Instance()
}
fmt.Scanln() // আউটপুট দেখতে অপেক্ষা করুন
}
এই উদাহরণে, Instance
ফাংশনটি এমন বৃহত সময়ে কল করা হলেও, সিংগেলটন অবজেক্টের তৈরি হয় শুধুমাত্র একবার। পরবর্তী কল শূন্য (শূন্য) ইনস্ট্যান্স তুলে, প্রথম বারে তৈরি করা সিংগেলটন ইনস্ট্যান্সটি নিশ্চিত করা হয়।
2.8 ErrGroup
ErrGroup
হলউস সিঙ্ক্রোনাইজ মাল্টিপল গোরুটিন এবং তাদের ত্রুতি সংগ্রহ করার জন্য ব্যবহৃত গো ভাষার একটি লাইব্রেরি। এটি "golang.org/x/sync/errgroup" প্যাকেজের অংশ, সময়সূচীভিত্তিক অপারেশনে ভুলের পরিস্থিতি নিয়ে সারসংক্ষেপভাবে নিয়ন্ত্রণের একটি সহজ উপায় সরবরাহ করে।
2.8.1 পরিকল্পনা এর ধারণা
ErrGroup
এর মৌলিক ধারণাটি হল সংশ্লিষ্ট কাজের একগুছি টাস্ককে সঙ্গে জড়িত করা (সাধারণত সময়সূচীভিত্তিক অনুষ্ঠান করা হয়) এবং যদি এই কাজের মধ্যে কোনও একটি টাস্ক ব্যর্থ হয়, তাহলে সম্পূর্ণ গোপনীয় অব্যাহত হবে৷ একই সময়ে, যদি এই সময়সূচীভিত্তিক অনুষ্ঠানে যে কোনও অপরাধটি ফিরে আসে, তবে ErrGroup
এই অপরাধটি জড়িত করবে এবং এই ত্রুতি ফিরিয়ে দেবে
if err := g.Wait(); err != nil {
// ত্রুতি সম্পাদন
log.Fatalf("টাস্ক অভিজ্ঞতা ত্রুতি: %v", err)
}
2.8.2 ErrGroup এর ব্যবহার
একটি স্কেনারিতে যেখানে আমাদের তিনটি পৃথক ডেটা উৎস থেকে একই সময়ে তথ্য পেতে হবে, এবং যদি কোনো ডেটা উৎস ব্যর্থ হয়, তবে আমরা চাইবো অন্য ডেটা পেতে যাওয়া উপস্থিতি অবিরত করা যায়। এই কাজটি সহজেই ErrGroup
ব্যবহার করে সম্পন্ন করা যায়।
package main
import (
"fmt"
"golang.org/x/sync/errgroup"
)
func fetchDataFromSource1() error {
// সোর্স 1 থেকে তথ্য পেতে সিমুলেট করা
return nil // বা একটি ত্রুটি সিমুলেট করতে একটি ত্রুটি রিটার্ন করুন
}
func fetchDataFromSource2() error {
// সোর্স 2 থেকে তথ্য পেতে সিমুলেট করা
return nil // বা একটি ত্রুটি সিমুলেট করতে একটি ত্রুটি রিটার্ন করুন
}
func fetchDataFromSource3() error {
// সোর্স 3 থেকে তথ্য পুনরাবৃত্তি করুন
return nil // বা একটি ত্রুটি সিমুলেট করতে একটি ত্রুটি রিটার্ন করুন
}
func main() {
var g errgroup.Group
g.Go(fetchDataFromSource1)
g.Go(fetchDataFromSource2)
g.Go(fetchDataFromSource3)
// সমস্ত গোরুটিন সমাপ্তির জন্য অপেক্ষা করুন এবং তাদের ত্রুটিগুলি সংগ্রহ করুন
if err := g.Wait(); err != nil {
fmt.Printf("তথ্য পেতে সময়গুলি অতিক্রম করার সময় ত্রুটি হয়েছিল: %v\n", err)
return
}
fmt.Println("সমস্ত তথ্য সফলভাবে পেয়েছেন!")
}
এই উদাহরণে, fetchDataFromSource1
, fetchDataFromSource2
, এবং fetchDataFromSource3
ফাংশনগুলি বিভিন্ন ডেটা উৎস থেকে তথ্য পেতে সিমুলেট করে। এগুলি কে g.Go
মেথডে পাঠানো হয়েছে এবং বিভিন্ন গোরুটিনে ক্রিয়ান্বয়ন করা হয়েছে। যদি কোনও ফাংশন কোনও ত্রুটি রিটার্ন করে, তবে g.Wait
তা সঙ্গে তা ত্রুটি রিটার্ন করে যাবে, যা ত্রুটি ঘটে পরিস্থিতি বদলে ত্রুটি হ্যান্ডলিং করতে সাহায্য করবে। যদি সমস্ত ফাংশন সফলভাবে ক্রিয়ান্বয়ন করে, তবে g.Wait
নিল রিটার্ন করবে, যা প্রদান করবে যে সমস্ত কাজগুলি সফলভাবে সম্পন্ন হয়েছে।
ErrGroup
এর আরও একটি গুরুত্বপূর্ণ বৈশিষ্ট্য হল যদি কোনও গোরুটিন প্যানিক করে, তবে এটি প্রচেষ্টা করবে যে এই প্যানিক রক্ষা করা এবং তা ত্রুটি হিসেবে ফিরিয়ে দেবে। এটা সহায়ক হয় অন্য সময় রান হওয়া গোরুটিনগুলি পরিপূর্ণভাবে বন্ধ না করতে। নিশ্চিতভাবে, আপনি যদি কাজগুলি বাহ্যিক বাতিল সিগনালগুলির জন্য প্রতিক্রিয়া দেয়া চান, তবে আপনি কনটেক্স্ট প্যাকেজ দিয়ে errgroup
এর WithContext
ফাংশনটি যোগ করতে পারেন।
এভাবে, ErrGroup
হয় গো সমপ্রবর্তন এবং ত্রুটি হ্যান্ডলিং ম্যাকানিজম হিসেবে একটি বেশ কার্যকরী সিঙ্ক্রোনাইজেশন হয় Go এর সমীপকারিতা উদাহরণ।