外部プログラムとの連系

#!/usr/bin/env ruby
# coding: euc-jp

lineno = 0                      # 行番号をつける
IO.popen("cal", "r") do |c|
  while line=c.gets
    printf("%d: %s", lineno+=1, line)
  end
end

IO.popen(子プロセス, "r+") do |c|
  c.puts データ
  c.close_write
  while line = c.gets
    「lineを利用した処理」
  end
end

#!/usr/bin/env ruby
# coding: euc-jp
# ./cat-n.rb 5000 とすれば5000回。省略時1000回。

repeat = (ARGV[0] || 1000).to_i
IO.popen("cat -n", "r+") do |c|
  0.upto(repeat) {|i| c.puts i}
  c.close_write
  while line=c.gets
    print line
  end
end

#!/usr/bin/env ruby
# coding: euc-jp
# ./cat-n.rb 5000 とすれば5000回。省略時1000回。

repeat = (ARGV[0] || 1000).to_i
IO.popen("cat -n", "r+") do |c|
  Thread.new {
    0.upto(repeat) {|i| c.puts i}
    c.close_write
  }
  while line=c.gets
    print line
  end
end

#!/bin/sh

echo -n "何ヶ月分?: " 1>&2
read n
if [ "$n" -le 0 ]; then		# 数字以外があるとコケる。要エラーチェック。
  echo "無効な指定です。1以上の数を指定して下さい。" 1>&2
  exit 1
fi
m=`date +%m`
y=`date +%Y`
while [ "$n" -gt 0 ]; do
  if [ $m -lt 12 ]; then
    m=1; y=`expr $y + 1`
  fi
  cal $m $y
  m=`expr $m + 1`
  n=`expr $n - 1`
done

#!/usr/bin/env ruby
# coding: euc-jp
require 'open3'
prog = "./ioe.sh"

STDERR.print "指定した月数分だけカレンダーを出力します。
何ヶ月分出しますか: "
n = gets.to_i                   # 英字だけなどは0になる。
Open3.popen3(prog) do |i, o, e|
  Thread.new {                  # 子プロセスの標準入力
    i.puts n.to_s               # つまり自分(親)からの出力
    i.close
  }
  Thread.new {
    while line=e.gets		# 子プロセスの標準エラー出力
      # ここでは特に処理しない
    end
  }
  while line=o.gets             # 子プロセスの標準出力
    print line
  end
end

#!/usr/bin/env ruby
# coding: euc-jp

repeat = (ARGV[0] || 5).to_i	# ./pipe.rb 10 とすると10回，省略時5回
io = IO.pipe
io[1].puts "あいうえお "*repeat	# 文字列を指定した回数繰り返したものを書き出す
io[1].flush
print io[0].gets

#!/usr/bin/env ruby
# coding: euc-jp
prog = "./ioe.sh"

STDERR.print "指定した月数分だけカレンダーを出力します。
何ヶ月分出しますか: "
n = gets.to_i                   # 英字だけなどは0になる。
STDOUT.flush

i = IO.pipe                     # 子プロセスの標準入力とのパイプ
o = IO.pipe                     # 子プロセスの標準出力とのパイプ
e = IO.pipe                     # 子プロセスの標準エラー出力とのパイプ
STDOUT.flush

if pid=fork 
  i[1].puts n.to_s
  i[1].close                    # 書き出しが終了したのでクローズ
  i[0].close                    # 以下，使わないのでクローズ
  o[1].close; e[1].close
  while line=o[0].gets
    print ":"+line		# コロンを付けて出力
  end
else
  i[1].close; o[0].close; e[0].close # 使わないのでクローズ
  STDIN.reopen(i[0])            # STDINの置き換え
  STDOUT.reopen(o[1])           # STDOUTの置き換え
  STDERR.reopen(e[1])           # STDERRの置き換え
  exec(prog)
end

#!/usr/bin/env ruby
# coding: euc-jp
require 'kconv'			# 漢字コードを揃えるため(1.8+1.9)

if !ARGV[0]
  STDERR.puts "再生したいファイルを指定して下さい。\n用法:"
  STDERR.puts "\t#{$0} <MP3ファイル(群)>"
  exit 1
end
frame = nil                     # 生成中フレーム# の保存用
e = IO.pipe                     # mpg123からは標準エラー出力のみ読み取る

pid = fork do                   # fork&exec を行なう。PIDを記憶。
  STDERR.printf("ちわ，子です。%s を演奏します。", ARGV.join(" "))
  STDERR.reopen(e[1])
  e[0].close                    # 入力端は使わないので閉じる
  exec "mpg123", "-v", *ARGV    # *ARGVで配列を展開して渡す
end
# ここから親の処理
e[1].close                      # 親の出力端は使わないので閉じる

def prompt(file)
  STDERR.printf("\n[%s]再生中 - コマンド(nで次の曲，qで終了): ", file)
end

Thread.new do                   # 子プロセス(mpg123)と通信するスレッド
  while not e[0].closed?
    line = ""
    while l = e[0].getc         # 1字ずつ読み、lineに足していく。
      if l != "\r"[0] && l != "\n"[0]   # CRかLF以外なら
        line << l.chr           # lineに追加
      else                      # CRかLFが来たら行(line)の完成
        break                   # ループを抜けてパターンマッチに移る
      end
    end
    if /Frame\#\s*(\d+)/ =~ line.toeuc
      STDERR.printf "%s ", $1 if $DEBUG
      frame = $1.to_i
    elsif /stream .* (.+) \.\.\./ =~ line.toeuc
      prompt($1)          # 再生ファイル名パターンが来たらプロンプト出力
    end
  end
end

Thread.new do			# プロセスの終了を監視するスレッド
  Process.wait                  # mpg123終了まで待機
  printf("Stopping at frame %s\n", frame)
  exit 0                        # mpg123が終了したらこのプログラムも終わる。
end

while true
  a = STDIN.gets                # promptが出ているはず
  if a.nil? || /q/ =~ a
    Process.kill(:INT, pid)     # mpg123コマンドに
    Process.kill(:INT, pid)     # 2連続でINTシグナルを送ると終了
    break
  elsif /n/ =~ a
    Process.kill(:INT, pid)     # 1回INTシグナル送信で次の曲へ
  end
end