থ্রেডপুল এক্সিকিউটর

একটি মাল্টি-থ্রেডেড অ্যাপ্লিকেশন বিকাশ করার সময়, আমাদের সাধারণত থ্রেডের কাজ সংগঠিত করার সাথে মোকাবিলা করতে হবে। আমাদের অ্যাপ্লিকেশন যত বড় হবে এবং মাল্টিথ্রেডেড কাজের জন্য আমাদের যত বেশি থ্রেড প্রয়োজন হবে, তত বেশিচলমানআমরা যে বস্তু তৈরি করি।

এখানে উল্লেখ্য যে জাভাতে একটি থ্রেড তৈরি করা একটি বরং ব্যয়বহুল অপারেশন। যদি আমরা প্রতিবার একটি অপারেশন করার জন্য থ্রেডের একটি নতুন উদাহরণ তৈরি করি, আমরা কর্মক্ষমতা এবং ফলস্বরূপ, অ্যাপ্লিকেশনের স্বাস্থ্যের সাথে বড় সমস্যা পাব।

একটি থ্রেড পুল এবং ThreadPoolExecutor এখানে আমাদের সাহায্যে আসে।

একটি থ্রেড পুল হল প্রাক-প্রাথমিক থ্রেডের একটি সেট। এর আকার স্থির বা পরিবর্তনশীল হতে পারে।

যদি থ্রেডের চেয়ে বেশি কাজ থাকে, তাহলে কাজগুলি একটি টাস্ক সারিতে অপেক্ষা করে। পুলের Nth থ্রেডটি সারি থেকে একটি টাস্ক নেয় এবং এটি সম্পন্ন হওয়ার পরে, থ্রেডটি সারি থেকে একটি নতুন কাজ গ্রহণ করে। সারিতে থাকা সমস্ত কাজ শেষ হয়ে গেলে, থ্রেডগুলি সক্রিয় থাকে এবং নতুন কাজের জন্য অপেক্ষা করে। যখন নতুন কাজগুলি উপস্থিত হয়, থ্রেডগুলিও সেগুলি কার্যকর করা শুরু করে।

থ্রেডপুল এক্সিকিউটর

জাভা 5 দিয়ে শুরু করে, এক্সিকিউটর ফ্রেমওয়ার্ক একটি মাল্টিথ্রেডিং সমাধান পেয়েছে। সাধারণভাবে, এতে প্রচুর উপাদান রয়েছে এবং এর উদ্দেশ্য হল সারি এবং থ্রেড পুলগুলিকে দক্ষভাবে পরিচালনা করতে আমাদের সাহায্য করা।

প্রধান ইন্টারফেস হল এক্সিকিউটর এবং এক্সিকিউটর সার্ভিস ।

এক্সিকিউটর হল একটি ইন্টারফেস যার একটি একক অকার্যকর এক্সিকিউট (রাননেবল রানেবল) পদ্ধতি।

এই পদ্ধতির বাস্তবায়নে একটি কাজ পাস করার সময়, জেনে রাখুন যে এটি ভবিষ্যতে অ্যাসিঙ্ক্রোনাসভাবে কার্যকর করা হবে।

ExecutorService — একটি ইন্টারফেস যা এক্সিকিউটর ইন্টারফেসকে প্রসারিত করে, কার্য সম্পাদনের জন্য ক্ষমতা যোগ করে। এটিতে চলমান টাস্কে বাধা দেওয়ার এবং থ্রেড পুলটি বন্ধ করার পদ্ধতি রয়েছে।

ThreadPoolExecutor এক্সিকিউটর এবং এক্সিকিউটরসার্ভিস ইন্টারফেস প্রয়োগ করেএবং টাস্ক এক্সিকিউশন থেকে টাস্ক তৈরিকে আলাদা করে। আমাদের রানেবল অবজেক্টগুলি বাস্তবায়ন করতে হবেএবং সেগুলিকে একজন নির্বাহকের কাছে পাঠাতে হবে। ThreadPoolExecutorতারপর কাজগুলি সম্পাদন করার জন্য এবং থ্রেড তৈরি এবং কাজ করার জন্য দায়ী ।

একটি কার্য সম্পাদনের জন্য পাঠানোর পরে, পুলের একটি বিদ্যমান থ্রেড ব্যবহার করা হয়। এই কর্মক্ষমতা উন্নত. এটি একটি নতুন থ্রেড তৈরি এবং শুরু করার জন্য সম্পদ নষ্ট করার সমস্যা সমাধান করে, এবং তারপরে আবার আবর্জনা সংগ্রহের উপর একবার আমরা থ্রেডটি শেষ করে ফেলি।

ThreadPoolExecutor এর 4 কনস্ট্রাক্টর আছে:

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit, 
BlockingQueue<Runnable> workQueue)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory, 
RejectedExecutionHandler handler)
    

ThreadPoolExecutor কনস্ট্রাক্টরের নিম্নলিখিত পরামিতি রয়েছে :

একটি ThreadPoolExecutor তৈরি করা হচ্ছে

এক্সিকিউটর ইউটিলিটি ক্লাস একটি ThreadPoolExecutor তৈরিকে সহজ করতে পারে । এই ইউটিলিটি ক্লাসের পদ্ধতিগুলি আমাদের একটি প্রস্তুত করতে সাহায্য করেথ্রেডপুল এক্সিকিউটরবস্তু

ExecutorService executor = Executors.newFixedThreadPool(10);
                    

ExecutorService executor = Executors.newWorkStealingPool(4);
                    

ExecutorService executor = Executors.newSingleThreadExecutor();
                    

ExecutorService executor = Executors.newCachedThreadPool();
                    

ScheduledExecutorService executor = Executors.newScheduledThreadPool(10);
                    

আমরা নিম্নলিখিত পাঠে প্রতিটি ধরণের পুল বিবেচনা করব।