عند دراسة الشيفرة التي قدمتها في السياق البرمجي الخاص بـ Spring Scheduler، يظهر أن هناك تأخيرًا في تنفيذ المهام المجدولة بسبب الطريقة التي تم فيها تكوين الـ Scheduler الخاص بك.
في الشيفرة التي قدمتها، تستخدم الكلاسين ComponentA و ComponentB الإشارة @Scheduled(fixedRate=2000)، وهذا يعني أن المهام ستقوم بالتنفيذ بفاصل زمني ثابت يساوي 2000 ميلي ثانية (2 ثانية). ولكن، على الرغم من ذلك، يتم تنفيذ المهمة الثانية (ComponentB) بعد انتهاء المهمة الأولى (ComponentA) بشكل متتالي.
لتحقيق التنفيذ المتزامن وتشغيل المهام بشكل متوازي، يمكنك تخصيص TaskExecutor خاص بك. يمكنك القيام بذلك عن طريق تعريف TaskExecutor في تكوين التطبيق الخاص بك وتحديده لاستخدامه مع الـ Scheduler.
فيما يلي مثال على كيفية تحقيق ذلك:
javaimport org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
@Configuration
@EnableScheduling
public class MyApplicationConfig {
@Bean
public ThreadPoolTaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(5); // تحديد عدد الخيوط الأساسي
executor.setMaxPoolSize(10); // تحديد الحد الأقصى لعدد الخيوط
executor.setThreadNamePrefix("my-scheduled-task-"); // تحديد بادئة اسم الخيط
executor.initialize();
return executor;
}
}
ثم قم بتحديد TaskExecutor الخاص بك في الكلاس الرئيسي MyApplication:
javaimport org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
@SpringBootApplication
@EnableScheduling
public class MyApplication {
public static void main(String[] args) {
SpringApplication.run(MyApplication.class, args);
}
}
باستخدام هذا الإعداد، يجب أن يتم تشغيل المهام المجدولة بشكل متزامن وفقًا لتكوين TaskExecutor الخاص بك.
المزيد من المعلومات
بالطبع، دعنا نعمق أكثر في الشرح. عندما ننظر إلى الكود البرمجي الذي قدمته، يظهر أنه تم استخدام تكنولوجيا Spring لجدولة المهام (@Scheduled). ومع ذلك، يوجد تحدي في تنفيذ هذه المهام بشكل متوازٍ.
في Spring، يعتمد التنظيم الزمني الافتراضي للمهام المجدولة على الـ Single Thread Executor، وهو يستخدم خيطًا واحدًا لتنفيذ المهام المجدولة. وهذا هو السبب في ظهور التنفيذ التتابعي للمهام في الناتج الذي قدمته.
لتحسين هذا وتمكين التنفيذ المتوازي، يتعين عليك تكوين TaskExecutor خاص بك، كما قمت بتوضيحه في الإجابة السابقة. في هذا السياق، يمكنك تعديل عدد الخيوط (corePoolSize و maxPoolSize) والبادئة التي تُستخدم لتسمية الخيوط (threadNamePrefix) وفقًا لاحتياجات التطبيق الخاص بك.
من الجدير بالذكر أن زيادة عدد الخيوط يمكن أن تؤدي إلى استهلاك موارد أكبر، لذا يجب أن تكون حذرًا عند تحديد قيم هذه المعلمات وضبطها وفقًا لطبيعة التطبيق ومتطلبات الأداء.
باختصار، عند تكوين TaskExecutor بشكل صحيح، يمكنك تحقيق التنفيذ المتوازي للمهام المجدولة في تطبيقك الذي يستخدم Spring Framework.
