Ruby/Kernel/select

يستدعي هذا التابع نظام الاستدعاء select(2)‎. ويقوم بمراقبة (monitors) المصفوفات المعطاة المكونة من كائنات IO، وينتظر حتى يكون أحد كائنات IO جاهزًا للقراءة ، وللكتابة، ويكون لها استثناءات معلقة (pending exceptions) تواليًا، ثم يعيد مصفوفة تحتوي على مصفوفات مكونة من كائنات IO السابقة.

ستُعاد القيمة nil إذا تم إعطاء قيمة للوسيط الاختياري timeout، ولم يكن هناك أي كائن IO جاهز خلال timeout ثانية.

تراقب IO.select المخزن المؤقت (buffer) لكائنات IO لاختبار قابليتها للقراءة. إذا لم يكن المخزن المؤقت IO فارغًا، فسيقوم التابع IO.select على الفور بالابلاغ عن جاهزية القراءة. هذه المراقبة لا تشمل إلا كائنات IO. ولا تحدث للكائنات شبيهة IO مثلOpenSSL::SSL::SSLSocket.

أفضل طريقة لاستخدام IO.select هي باستدعائها عقِب التوابع غير المُعطّلة (nonblocking methods)، مثل read_nonblock و write_nonblock ، وغيرهما. تطلق التوابع استثناء، والذي يُوسّع بواسطة IO::WaitReadable أو IO::WaitWritable. تقوم الوحدات (modules) بالابلاغ عن كيف ينبغي للمُستدعي (caller) الانتظار مع IO.select. في حال إطلاق IO::WaitReadable ، فسيكون على المُستدعي أن ينتظر لأجل القراءة. وفي حال إطلاق IO::WaitWritable، فيجب على المُستدعي أن ينتظر لأجل الكتابة.

لذلك، يمكن محاكاة حظر القراءة (readpartial) باستخدام read_nonblock و IO.select على النحو التالي:

begin
  result = io_like.read_nonblock(maxlen)
rescue IO::WaitReadable
  IO.select([io_like])
  retry
rescue IO::WaitWritable
  IO.select(nil, [io_like])
  retry
end

عمومًا، يُفضل الجمع بين التوابع غير المُعطلة و IO.select بالنسبة للكائنات شبيهة IO، مثل OpenSSL::SSL::SSLSocket. إذ يعيد تابعهاto_io الكائن IO الأساسي. كما يستدعي IO.select التابع to_io لأجل الحصول على واصف الملف (file descriptor) المُنتظر.

هذا يعني أن الإبلاغ عن قابلية القراءة من طرف IO.select لا تعني إمكانية القراءة من الكائن OpenSSL::SSL::SSLSocket.

على الأرجح أنّ OpenSSL::SSL::SSLSocket تخزّن مؤقتا بعض البيانات. لكن لا يرى IO.select المخزن المؤقت (buffer). لذلك يمكنه أن يُعطل (block) عندما لا يفعل OpenSSL::SSL::SSLSocket#readpartial. لكن توجد حالات أكثر تعقيدًا.

SSL هو بروتوكول، وهو عبارة عن تسلسل للسجلات (sequence of records). تتكون السجلات من عدة بتات. لذا، يرسل الجانب البعيد من SSL سجلًا جزئيًا، يقوم IO.select بالابلاغ عن إمكانية القراءة، ولكن لا يمكن لـ OpenSSL::SSL::SSLSocket فك التشفير البايتات، فيقوم OpenSSL::SSL::SSLSocket#readpartial بالتعطيل.

يمكن أيضًا للجانب البعيد أن يطلب إعادة تفاوض أمني SSL، والذي سيُجبر محرك SSL المحلي على كتابة بعض البيانات. هذا يعني أنّ OpenSSL::SSL::SSLSocket#readpartial قد يستدعي نظام الاستدعاء write ويمكنه التعطيل في مثل هذه الحالة، يُطلق OpenSSL::SSL::SSLSocket#read_nonblock الاستثناء IO::WaitWritable، بدلاً من التعطيل. لذلك، سيكون على المتصل الانتظار إلى حين جاهزية الكتابة كما هو مذكور أعلاه.

الجمع بين التوابع غير المُعطلة و IO.select مفيد أيضًا للمجاري (streams) مثل tty ، والقنوات (pipe socket)، عندما تقوم عدة عمليات بالقراءة من مجرى معيّن.

وأخيراً، لا يمكن لمطوري نواة لينكس (Linux kernel developers) أن يكونوا على يقين بأنّ قابلية القراءة select(2)‎ تعني قابلية القراءة لـ read(2)‎ حتى ولو في نفس العملية. انظر توثيق select(2) ‎ في نظام جنو / لينكس.

استدعاء IO.select قبل IO#readpartial يعمل بشكل جيد كالمعتاد. لكنه ليس الطريقة المثلى لاستخدام IO.select.

لا تُظهر قابلية الكتابة المُبلغ عنها من طرف select (2)‎ عن عدد البايتات القابلة للكتابة. يتعطّل التابع IO#write إلى حين كتابة السلسلة النصية المعطاة كاملة. لذلك ، يمكن أن يُعطل IO#write(two or more bytes)‎ بعد الابلاغ عن قابلية الكتابة من قبل IO.select. لتجنب التعطيل، لا بد من استخدامIO#write_nonblock.

يمكن محاكاة تعطيل الكتابة (write) باستخدام write_nonblock و IO.select كما يلي: يجب أن يتم حفظ IO::WaitReadable لأجل إعادة التفاوض الأمني SSL في OpenSSL::SSL::SSLSocket.

while 0 < string.bytesize
  begin
    written = io_like.write_nonblock(string)
  rescue IO::WaitReadable
    IO.select([io_like])
    retry
  rescue IO::WaitWritable
    IO.select(nil, [io_like])
    retry
  end
  string = string.byteslice(written..-1)
end

البنية العامة

select(read_array [, write_array [, error_array [, timeout]]]) → array or nil‎

المعاملات

read_array‎

مصفوفة من كائنات IO التي تنتظر إلى حين جاهزية القراءة.

write_array‎

مصفوفة من كائنات IO، والتي تنتظر حتى جاهزية الكتابة

error_array‎

مصفوفة من كائنات IO التي تنتظر الاستثناءات

timeout‎

قيمة عددية تمثل عدد ثواني الانتظار.

القيمة المُعادة

يعيد مصفوفة تحتوي على مصفوفات مكونة من كائنات IO السابقة. ستُعاد القيمة nil إذا تم إعطاء قيمة للوسيط الاختياري timeout، ولم يكن هناك أي كائن IO جاهز خلال timeout ثانية.

أمثلة

مثال على استخدام التابع select‎:

rp, wp = IO.pipe
mesg = "ping "
100.times {
  # IO.select follows IO#read.  Not the best way to use IO.select.
  rs, ws, = IO.select([rp], [wp])
  if r = rs[0]
    ret = r.read(5)
    print ret
    case ret
    when /ping/
      mesg = "pong\n"
    when /pong/
      mesg = "ping "
    end
  end
  if w = ws[0]
    w.write(mesg)
  end
}

الناتج:

ping pong
ping pong
ping pong
(snipped)
ping

انظر أيضا

• التابع require_relative: عند استدعاء هذا التابع ستحاول روبي تحميل المكتبة المسماة في الوسيط المعطى string نسبة إلى مسار الملف المطلوب. إذا تعذر تحديد مسار الملف، سيُطلق خطأ LoadError. إذا تم تحميل ملف ستُعاد القيمة true، وإلا فستُعاد false على خلاف ذلك.
• التابع set_trace_func: يجعل التابع set_trace_func الوسيط المعطى proc كمتعقب (handler for tracing)، أو يعطل التعقب إن كان الوسيط يساوي nil.

مصادر

• قسم التابع select‎ في الصنف Kernel‎ في توثيق روبي الرسمي.