Ruby/マルチスレッドの変更点

追加された行はこの色です。
削除された行はこの色です。
Ruby/マルチスレッドへ行く。
* マルチスレッド [#de9f6437]

 #!/usr/bin/ruby
 
 require("open3");
 
 cmd= "flac --decode --stdout " +
      "\"_inFile_\"  |  " +
      "/home/kosame/src/lame-3.99.5/frontend/lame " +
      "-V 5 -b 128 " +
      "- " +
      "\"_outFile_\"";
 maxProcNum   = 4;
 coreUseFlag  = [];
 procFileName = [];
 myStdIn      = [];
 myStdOut     = [];
 myStdErr     = [];
 myWaitThr    = [];
 0.upto(maxProcNum-1){|i|
   coreUseFlag [i]= false;
   procFileName[i]= "";
   myStdIn     [i]= nil;
   myStdOut    [i]= nil;
   myStdErr    [i]= nil;
   myWaitThr   [i]= nil;
 }
 files= [];
 
 printf("proc for files: \n");
 Dir::glob("*.flac"){|f|
   files.push(f);
   printf("  %s\n", f);
 }
 
 totalFileNum = files.size();
 finFileNum   = 0;
 
 controllerThreadState= true;
 
 # controller thread ########################################
 Thread.fork {
   while(true)
     # assign one process
     cix= coreUseFlag.index(false)
     if( cix != nil )
       if(files.size() > 0)
         # raise proccess
         fileName= files.pop();
         cmdbuf= cmd.gsub("_inFile_", fileName );
         cmdbuf= cmdbuf.sub("_outFile_", fileName.sub(/\.flac$/, ".mp3") );
         # printf(":::: command :::: %s\n", cmdbuf);
         # printf(":::: run : %s\n", fileName);
         myStdIn[cix],
         myStdOut[cix],
         myStdErr[cix],
         myWaitThr[cix] =
         *Open3.popen3( cmdbuf );
         # check flag
         coreUseFlag[cix] = true;
         procFileName[cix]= fileName;
       else
         # printf("no more target file\n");
       end
     else
       # printf("no empty slot.\n");
     end
 
     # check wait thread
     aliveThread= false;
     0.upto(myWaitThr.size()-1){|i|
       if(myWaitThr[i] != nil)
         aliveThread= true;
 
         begin
           # printf("%s\n", myStdOut[i].read_nonblock() );
         rescue
           # printf("no buf\n");
         end
 
         if(myWaitThr[i].alive? == false)
           coreUseFlag[i]= false;
           finFileNum+= 1;
           printf( ">>>> file[%d/%d]: %s \n  is done\n",
                   finFileNum, totalFileNum, procFileName[i]);
           myStdOut[i].close();
           myStdErr[i].close();
           myStdIn[i].close();
           myWaitThr[i] = nil;
         end
       else
         # printf("myWaithThr[%d] is empty\n", i)
       end
     }
 
     # myWaitThr is all nil and
     # no more file?
     if((aliveThread == false) &
        (files.size() == 0))
       break;
     end
 
     # output stream
     sleep(0.2);
   end
 
   controllerThreadState= false;
 }
 
 # wait for controller thread
 while(true)
   sleep(0.2);
   if(controllerThreadState == false)
     break;
   end
 end