検索結果

Thread::Mutex#lock -> self (63307.0)

• 2.3.0

• インスタンスメソッド

mutex オブジェクトをロックします。一度に一つのス レッドだけが mutex をロックできます。既にロックされている mutex に対してロックを行おうとしたスレッドは mutex のロックが解放さ れるまで、実行が停止されます。

mutex オブジェクトをロックします。一度に一つのス
レッドだけが mutex をロックできます。既にロックされている mutex
に対してロックを行おうとしたスレッドは mutex のロックが解放さ
れるまで、実行が停止されます。

@raise ThreadError self 既にカレントスレッドにロックされている場合に発
生します。
また、Signal.#trap に指定したハンドラ内で実行
した場合に発生します。


@see Thread::Mutex#unlock
...

• Thread::Mutex

Net::HTTP#lock(path, body, initheader = nil) -> Net::HTTPResponse (54673.0)

• 2.3.0

• インスタンスメソッド

サーバの path に LOCK リクエストを ヘッダを initheader, ボディを body として送ります。

サーバの path に LOCK リクエストを
ヘッダを initheader, ボディを body として送ります。

レスポンスを Net::HTTPResponse のオブジェクト
で返します。

@param path リクエストを送るパスを文字列で与えます。
@param body リクエストのボディを文字列で与えます。
@param initheader リクエストのヘッダを「文字列=>文字列」の
ハッシュで与えます。

@see Net::HTTP::Lock

• Net::HTTP
• Net::HTTP::Lock
• Net::HTTPResponse

Sync_m#lock(mode = EX) -> self (54610.0)

• 2.3.0

• インスタンスメソッド

ロック状態を変更します。 変更できるまで現在のスレッドの実行をブロックします。

ロック状態を変更します。
変更できるまで現在のスレッドの実行をブロックします。

@param mode 変更後の状態を指定します。
通常、 Sync_m::EX, Sync_m::SH のどれかを指定します。

• Sync_m

Thread::Mutex#locked? -> bool (36622.0)

• 2.3.0

• インスタンスメソッド

mutex がロックされている時、真を返します。

mutex がロックされている時、真を返します。

//emlist[例][ruby]{
m = Mutex.new
m.locked? # => false
m.lock
m.locked? # => true
//}

• Thread::Mutex

ARGF.class#read_nonblock(maxlen, outbuf = nil, exception: true) -> String | Symbol | nil (36604.0)

• 2.3.0

• インスタンスメソッド

処理中のファイルからノンブロッキングモードで最大 maxlen バイト読み込みます。 詳しくは IO#read_nonblock を参照してください。

処理中のファイルからノンブロッキングモードで最大 maxlen バイト読み込みます。
詳しくは IO#read_nonblock を参照してください。

ARGF.class#read などとは違って複数ファイルを同時に読み込むことはありません。

@param maxlen 読み込む長さの上限を整数で指定します。
@param outbuf 読み込んだデータを格納する String オブジェクトを指定します。
@param exception 読み込み時に Errno::EAGAIN、
Errno::EWOULDBLOCK が発生する代わりに
...

• ARGF.class
• Errno::EAGAIN
• String

絞り込み条件を変える

BasicSocket#sendmsg_nonblock(mesg, flags=0, dest_sockaddr=nil, *controls) -> Integer (36604.0)

• 2.3.0

• インスタンスメソッド

sendmsg(2) を用いてノンブロッキング方式でメッセージを送ります。

sendmsg(2) を用いてノンブロッキング方式でメッセージを送ります。

詳しくは BasicSocket#sendmsg を見てください。

@return 送ったバイト数
@param mesg メッセージ文字列
@param flags フラグ(Socket::MSG_* という定数の bitwise OR を取ったもの)
@param dest_sockaddr 通信先のアドレス
@param controls 補助データの配列
@see BasicSocket#sendmsg

• BasicSocket

File::Stat#blockdev? -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

ブロックスペシャルファイルの時に真を返します。

ブロックスペシャルファイルの時に真を返します。

//emlist[][ruby]{
Dir.glob("/dev/*") {|bd|
if File::Stat.new(bd).blockdev?
puts bd
end
}
#例
#...
#=> /dev/hda1
#=> /dev/hda3
#...
//}

• File::Stat

IO#read_nonblock(maxlen, outbuf = nil, exception: true) -> String | Symbol | nil (36604.0)

• 2.3.0

• インスタンスメソッド

IO をノンブロッキングモードに設定し、 その後で read(2) システムコールにより 長さ maxlen を上限として読み込み、文字列として返します。 EAGAIN, EINTR などは Errno::EXXX 例外として呼出元に報告されます。

IO をノンブロッキングモードに設定し、
その後で read(2) システムコールにより
長さ maxlen を上限として読み込み、文字列として返します。
EAGAIN, EINTR などは Errno::EXXX 例外として呼出元に報告されます。

発生した例外 がErrno::EAGAIN、 Errno::EWOULDBLOCK である場合は、
その例外オブジェクトに IO::WaitReadable が Object#extend
されます。

なお、バッファが空でない場合は、read_nonblock はバッファから読み込みます。この場合、read(2) システムコールは呼ばれません...

• Errno::EAGAIN
• Errno::EXXX
• IO
• IO::WaitReadable

Mutex_m#locked? -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

self がロックされている時、真を返します。

self がロックされている時、真を返します。

• Mutex_m

Mutex_m#mu_locked? -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

self がロックされている時、真を返します。

self がロックされている時、真を返します。

• Mutex_m

絞り込み条件を変える

OpenSSL::Buffering#read_nonblock(maxlen, buf) -> String (36604.0)

• 2.3.0

• インスタンスメソッド

通信路から maxlen バイトを上限としてデータを読み込み、 文字列として返します。

通信路から maxlen バイトを上限としてデータを読み込み、
文字列として返します。

即座に得られるデータが 1byte でも存在すればブロックしません。
内部バッファが空でない場合はバッファのデータを返します。
即座に得られるデータが存在しないときには例外が発生します。
例外が発生した場合、内部のソケットが利用可能になってから
再びこのメソッドを呼んでください。

基本的には IO#read_nonblock と同様です。しかし以下のような
違いもあります。

このメソッドはソケットが書き込み不可能(IO::WaitWritable)という理由で
例外を発生させる可能性があります。暗号...

• IO::WaitWritable
• OpenSSL::Buffering

Pathname#blockdev? -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

FileTest.blockdev?(self.to_s) と同じです。

FileTest.blockdev?(self.to_s) と同じです。


@see FileTest.#blockdev?

• Pathname

Shell#blockdev?(file) -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

FileTest モジュールにある同名のクラスメソッドと同じです.

FileTest モジュールにある同名のクラスメソッドと同じです.

@param file ファイル名を表す文字列か IO オブジェクトを指定します。

@see FileTest.#blockdev?

• FileTest
• Shell

Shell::CommandProcessor#blockdev?(file) -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

FileTest モジュールにある同名のクラスメソッドと同じです.

FileTest モジュールにある同名のクラスメソッドと同じです.

@param file ファイル名を表す文字列か IO オブジェクトを指定します。

@see FileTest.#blockdev?

• FileTest
• Shell::CommandProcessor

Shell::Filter#blockdev?(file) -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

FileTest モジュールにある同名のクラスメソッドと同じです.

FileTest モジュールにある同名のクラスメソッドと同じです.

@param file ファイル名を表す文字列か IO オブジェクトを指定します。

@see FileTest.#blockdev?

• FileTest
• Shell::Filter

絞り込み条件を変える

StringIO#read_nonblock(maxlen, outbuf = nil, exception: true) -> String | nil (36604.0)

• 2.3.0

• インスタンスメソッド

StringIO#readに似ていますが、 exception オプションに false を指定すると EOFError を発生させず nil を返します。

StringIO#readに似ていますが、 exception オプションに false を指定すると EOFError を発生させず nil を返します。

@param len 読み込みたい長さを整数で指定します。StringIO#read と同じです。

@param outbuf 読み込んだ文字列を出力するバッファを文字列で指定します。指定した文字列オブジェクトが
あらかじめ length 長の領域であれば、余計なメモリの割当てが行われません。指定した文字列の
長さが length と異なる場合、その文字列は一旦 length ...

• StringIO

Sync_m#locked? -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

ロックされているかどうかを返します。

ロックされているかどうかを返します。

• Sync_m

Sync_m#sync_locked? -> bool (36604.0)

• 2.3.0

• インスタンスメソッド

ロックされているかどうかを返します。

ロックされているかどうかを返します。

• Sync_m

Thread::Mutex#try_lock -> bool (27343.0)

• 2.3.0

• インスタンスメソッド

mutex をロックしようとして、ロックが成功した場合、真を返します。 ロックできなかった場合にはブロックせず偽を返します。

mutex をロックしようとして、ロックが成功した場合、真を返します。
ロックできなかった場合にはブロックせず偽を返します。

//emlist[例][ruby]{
m = Mutex.new
m.try_lock # => true
m.try_lock # => false
//}

• Thread::Mutex

Thread::Mutex#unlock -> self (27340.0)

• 2.3.0

• インスタンスメソッド

mutex のロックを解放します。mutex のロック待ちになっていたスレッドの実行は再開されます。

mutex のロックを解放します。mutex のロック待ちになっていたスレッドの実行は再開されます。

@return self を返します。

例:

m = Mutex.new
begin
m.lock
# critical part
ensure
m.unlock
end

Mutex はロックしたスレッド以外からロックを開放することは出来ません。
ロックしたスレッド以外から unlock が呼ばれると ThreadError が発生します。

m = Mutex.new
m.lock
Thread.new do
m.unlock # => Thr...

• Thread::Mutex

絞り込み条件を変える

Digest::Base#block_length -> Integer (27304.0)

• 2.3.0

• インスタンスメソッド

ダイジェストのブロック長を取得します。 例えば、Digest::MD5であれば64、Digest::SHA512であれば128です。

ダイジェストのブロック長を取得します。
例えば、Digest::MD5であれば64、Digest::SHA512であれば128です。

本メソッドは、Digest::MD5などのダイジェストのサブクラスにより、
それぞれの実装に適したものにオーバーライドされます。

例: Digest::MD、Digest::SHA1、Digest::SHA512のブロック長を順番に調べる。

require 'digest'
["MD5", "SHA1", "SHA512"].map{|a| Digest(a).new().block_length } # => [64, 128, 128]

• Digest::Base

Digest::SHA2#block_length -> Integer (27304.0)

• 2.3.0

• インスタンスメソッド

ダイジェストのブロック長を返します。

ダイジェストのブロック長を返します。

• Digest::SHA2

OpenSSL::Digest#block_length -> Integer (27304.0)

• 2.3.0

• インスタンスメソッド

ハッシュ関数のブロックサイズを返します。

ハッシュ関数のブロックサイズを返します。

• OpenSSL::Digest

UDPSocket#recvfrom_nonblock(maxlen, flags=0) -> [String, Array] (27304.0)

• 2.3.0

• インスタンスメソッド

ソケットをノンブロッキングモードに設定した後、 recvfrom(2) でソケットからデータを受け取ります。

ソケットをノンブロッキングモードに設定した後、
recvfrom(2) でソケットからデータを受け取ります。

maxlen で受け取るデータの最大バイト数を指定します。

flags はフラグで、Socket::MSG_* の bitwise OR を渡します。
詳しくは recvfrom(2) を参照してください。

返り値はデータの文字列と送り元のアドレス情報の
2要素の配列となります。

recvfrom(2) がエラーになった場合、
Errno::EAGAIN, Errno::EINTR を含め例外 Errno::EXXX が発生します。
Errno::EWOULDBLOCK、Err...

• Errno::EXXX
• IO::WaitReadable
• UDPSocket

String#codepoints {|codepoint| block } -> self (18904.0)

• 2.3.0

• インスタンスメソッド

文字列の各コードポイントの配列を返します。(self.each_codepoint.to_a と同じです)

文字列の各コードポイントの配列を返します。(self.each_codepoint.to_a と同じです)

//emlist[例][ruby]{
#coding:UTF-8
"hello わーるど".codepoints
# => [104, 101, 108, 108, 111, 32, 12431, 12540, 12427, 12393]
//}

ブロックが指定された場合は String#each_codepoint と同じように動作します。

Ruby 2.6 までは deprecated の警告が出ますが、Ruby 2.7 で警告は削除されました。

@see String#e...

• String

絞り込み条件を変える

String#each_codepoint {|codepoint| block } -> self (18904.0)

• 2.3.0

• インスタンスメソッド

文字列の各コードポイントに対して繰り返します。

文字列の各コードポイントに対して繰り返します。

UTF-8/UTF-16(BE|LE)/UTF-32(BE|LE) 以外のエンコーディングに対しては
各文字のバイナリ表現由来の値になります。

//emlist[例][ruby]{
#coding:UTF-8
"hello わーるど".each_codepoint.to_a
# => [104, 101, 108, 108, 111, 32, 12431, 12540, 12427, 12393]
"hello わーるど".encode('euc-jp').each_codepoint.to_a
# => [104, 101, 108, 1...

• String

Sync_m#sync_lock(mode = EX) -> self (18610.0)

• 2.3.0

• インスタンスメソッド

ロック状態を変更します。 変更できるまで現在のスレッドの実行をブロックします。

ロック状態を変更します。
変更できるまで現在のスレッドの実行をブロックします。

@param mode 変更後の状態を指定します。
通常、 Sync_m::EX, Sync_m::SH のどれかを指定します。

• Sync_m

Sync_m#sync_try_lock(mode = EX) -> bool (18610.0)

• 2.3.0

• インスタンスメソッド

ロック状態を変更します。 変更できたかどうかをtrueかfalseで返し、ブロックしません。

ロック状態を変更します。
変更できたかどうかをtrueかfalseで返し、ブロックしません。

@param mode 変更後の状態を指定します。
通常、 Sync_m::EX, Sync_m::SH のどれかを指定します。

• Sync_m

Sync_m#try_lock(mode = EX) -> bool (18610.0)

• 2.3.0

• インスタンスメソッド

ロック状態を変更します。 変更できたかどうかをtrueかfalseで返し、ブロックしません。

ロック状態を変更します。
変更できたかどうかをtrueかfalseで返し、ブロックしません。

@param mode 変更後の状態を指定します。
通常、 Sync_m::EX, Sync_m::SH のどれかを指定します。

• Sync_m

BasicSocket#recvmsg_nonblock(maxmesglen=nil, flags=0, maxcontrollen=nil, opts={}) -> [String, Addrinfo, Integer, *Socket::AncillaryData] (18604.0)

• 2.3.0

• インスタンスメソッド

recvmsg(2) を用いてノンブロッキング方式でメッセージを受け取ります。

recvmsg(2) を用いてノンブロッキング方式でメッセージを受け取ります。

ブロッキングの有無以外は BasicSocket#recvmsg と同じです。
詳しくはそちらを参照してください。

@param maxmesglen 受け取るメッセージの最大長
@param flags フラグ
@param maxcontrollen 受け取る補助データの最大長
@param opts ハッシュオプション

• BasicSocket

絞り込み条件を変える

Net::HTTP#unlock(path, body, initheader = nil) -> Net::HTTPResponse (18604.0)

• 2.3.0

• インスタンスメソッド

サーバの path に UNLOCK リクエストを ヘッダを initheader, ボディを body として送ります。

サーバの path に UNLOCK リクエストを
ヘッダを initheader, ボディを body として送ります。

レスポンスを Net::HTTPResponse のオブジェクト
で返します。

@param path リクエストを送るパスを文字列で与えます。
@param body リクエストのボディを文字列で与えます。
@param initheader リクエストのヘッダを「文字列=>文字列」の
ハッシュで与えます。
@see Net::HTTP::Unlock

• Net::HTTP
• Net::HTTP::Unlock
• Net::HTTPResponse

OptionParser#on_head(*arg, &block) -> self (18604.0)

• 2.3.0

• インスタンスメソッド

オプションを取り扱うためのブロックを自身の持つリストの最初に登録します。

オプションを取り扱うためのブロックを自身の持つリストの最初に登録します。

@param arg OptionParser#on と同様です。

@param block OptionParser#on と同様です。

//emlist[例][ruby]{
require "optparse"

opts = OptionParser.new do |opts|
opts.on_head("-i", "--init")
opts.on("-u", "--update")
opts.on_tail("-h", "--help")
end

puts opts.help

# => ...

• OptionParser

Shell#cd(path, &block) -> self (18604.0)

• 2.3.0

• インスタンスメソッド

カレントディレクトリをpathにする. イテレータとして呼ばれたときには ブロック実行中のみカレントディレクトリを変更する.

カレントディレクトリをpathにする. イテレータとして呼ばれたときには
ブロック実行中のみカレントディレクトリを変更する.

@param path カレントディレクトリを文字列で指定します.

@param block path で指定したディレクトリで行う操作をブロックで指定します.

使用例
require 'shell'
sh = Shell.new
sh.transact {
cd("/tmp"){
p cwd #=> "/tmp"
}
p cwd #=> "/Users/kouya/rbmanual"
}

• Shell

Shell#chdir(path, &block) -> self (18604.0)

• 2.3.0

• インスタンスメソッド

カレントディレクトリをpathにする. イテレータとして呼ばれたときには ブロック実行中のみカレントディレクトリを変更する.

カレントディレクトリをpathにする. イテレータとして呼ばれたときには
ブロック実行中のみカレントディレクトリを変更する.

@param path カレントディレクトリを文字列で指定します.

@param block path で指定したディレクトリで行う操作をブロックで指定します.

使用例
require 'shell'
sh = Shell.new
sh.transact {
cd("/tmp"){
p cwd #=> "/tmp"
}
p cwd #=> "/Users/kouya/rbmanual"
}

• Shell

Shell#pushd(path = nil, &block) -> object (18604.0)

• 2.3.0

• インスタンスメソッド

カレントディレクトリをディレクトリスタックにつみ, カレントディレク トリをpathにする. pathが省略されたときには, カレントディレクトリと ディレクトリスタックのトップを交換する. イテレータとして呼ばれたと きには, ブロック実行中のみpushdする.

カレントディレクトリをディレクトリスタックにつみ, カレントディレク
トリをpathにする. pathが省略されたときには, カレントディレクトリと
ディレクトリスタックのトップを交換する. イテレータとして呼ばれたと
きには, ブロック実行中のみpushdする.

@param path カレントディレクトリをpathにする。文字列で指定します。

@param block イテレータとして呼ぶ場合, ブロックを指定します。

動作例
require 'shell'
Shell.verbose = false
sh = Shell.new
sh.pushd("/tmp"...

• Shell

絞り込み条件を変える

Shell#pushdir(path = nil, &block) -> object (18604.0)

• 2.3.0

• インスタンスメソッド

カレントディレクトリをディレクトリスタックにつみ, カレントディレク トリをpathにする. pathが省略されたときには, カレントディレクトリと ディレクトリスタックのトップを交換する. イテレータとして呼ばれたと きには, ブロック実行中のみpushdする.

カレントディレクトリをディレクトリスタックにつみ, カレントディレク
トリをpathにする. pathが省略されたときには, カレントディレクトリと
ディレクトリスタックのトップを交換する. イテレータとして呼ばれたと
きには, ブロック実行中のみpushdする.

@param path カレントディレクトリをpathにする。文字列で指定します。

@param block イテレータとして呼ぶ場合, ブロックを指定します。

動作例
require 'shell'
Shell.verbose = false
sh = Shell.new
sh.pushd("/tmp"...

• Shell

Socket#connect_nonblock(server_sockaddr) -> 0 (18604.0)

• 2.3.0

• インスタンスメソッド

ソケットをノンブロッキングモードに設定した後、 connect(2) を呼び出します。

ソケットをノンブロッキングモードに設定した後、
connect(2) を呼び出します。

引数、返り値は Socket#connect と同じです。

connect が EINPROGRESS エラーを報告した場合、その例外(Errno::EINPROGRESS)
には IO::WaitWritable が Object#extend されます。
これを connect_nonblock をリトライするために使うことができます。

# Pull down Google's web page
require 'socket'
include Socket::Constants
...

• IO::WaitWritable
• Socket

Socket#recvfrom_nonblock(maxlen, flags=0) -> [String, Addrinfo] (18604.0)

• 2.3.0

• インスタンスメソッド

ソケットをノンブロッキングモードに設定した後、 recvfrom(2) を呼び出します。

ソケットをノンブロッキングモードに設定した後、
recvfrom(2) を呼び出します。

引数、返り値は Socket#recvfrom と同じです。

recvfrom(2) がエラーになった場合、
EAGAIN, EINTR を含め例外 Errno::EXXX が発生します。
Errno::EWOULDBLOCK、Errno::EAGAIN のような待ってからリトライすることが
可能であることを意味する例外には、IO::WaitReadable が extend
されています。

@param maxlen ソケットから受けとるデータの最大値
@param flags フラグ
@rai...

• Errno::EXXX
• IO::WaitReadable
• Socket

Sync_m#sync_ex_locker -> Thread | nil (18604.0)

• 2.3.0

• インスタンスメソッド

@todo

@todo

• Sync_m

Sync_m#sync_ex_locker=(thread) (18604.0)

• 2.3.0

• インスタンスメソッド

@todo

@todo

• Sync_m

絞り込み条件を変える

Sync_m#sync_unlock(mode = EX) -> self (18604.0)

• 2.3.0

• インスタンスメソッド

ロックを解除します。

ロックを解除します。

@param mode 変更後の状態を指定します。
通常、 Sync_m::UN, Sync_m::EX, Sync_m::SH のどれかを指定します。

• Sync_m

Sync_m#unlock(mode = EX) -> self (18604.0)

• 2.3.0

• インスタンスメソッド

ロックを解除します。

ロックを解除します。

@param mode 変更後の状態を指定します。
通常、 Sync_m::UN, Sync_m::EX, Sync_m::SH のどれかを指定します。

• Sync_m

Syslog::Logger#add(severity, message = nil, progname = nil, &block) -> true (18604.0)

• 2.3.0

• インスタンスメソッド

メッセージをログに記録します。Logger#add とほぼ同じ動作をします。

メッセージをログに記録します。Logger#add とほぼ同じ動作をします。

ブロックを与えた場合はブロックを評価した返り値をメッセージとしてログに
記録します。 ユーザがこのメソッドを直接使うことはあまりありません。

@param severity ログレベル。Logger クラスで定義されている定数を指定しま
す。この値がレシーバーに設定されているレベルよりも低い
場合、メッセージは記録されません。

@param message ログに出力するメッセージを表すオブジェクトを指定します。
省...

• Syslog::Logger

Syslog::Logger#debug(message = nil, &block) -> true (18604.0)

• 2.3.0

• インスタンスメソッド

DEBUG 情報を出力します。syslog の DEBUG の情報として記録されます。

DEBUG 情報を出力します。syslog の DEBUG の情報として記録されます。

ブロックを与えなかった場合は、message をメッセージとしてログを出力します。

ブロックを与えた場合は、ブロックを評価した結果をメッセージとして ログを出力します。

引数とブロックを同時に与えた場合は、message をメッセージとしてログを出
力します(ブロックは評価されません)。

@see Syslog::Logger::LEVEL_MAP, Logger#debug

• Syslog::Logger

Thread::Queue#deq(non_block = false) -> object (18604.0)

• 2.3.0

• インスタンスメソッド

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = Queue.new

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}

t...

• Thread::Queue
• ThreadError

絞り込み条件を変える

Thread::SizedQueue#deq(non_block = false) -> object (18604.0)

• 2.3.0

• インスタンスメソッド

キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。

キューからひとつ値を取り出します。
キューに push しようと待っているスレッドがあれば、実行を再開させます。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].eac...

• Thread::SizedQueue
• ThreadError

Thread::Mutex#owned? -> bool (18322.0)

• 2.3.0

• インスタンスメソッド

self がカレントスレッドによってロックされている場合に true を返します。 そうでない場合に false を返します。

self がカレントスレッドによってロックされている場合に true を返します。
そうでない場合に false を返します。


//emlist[例][ruby]{
m = Mutex.new
m.owned? # => false
m.lock
Thread.new do
m.owned? # => false
end.join
m.owned? # => true
//}

• Thread::Mutex

Fiddle::Closure::BlockCaller#call(*args) -> object (18004.0)

• 2.3.0

• インスタンスメソッド

wrap しているブロックを呼び出します。

wrap しているブロックを呼び出します。

そのブロックの返り値がこのメソッドの返り値となります。

@param args 引数

• Fiddle::Closure::BlockCaller

Gem::Commands::LockCommand#complain(message) -> () (18004.0)

• 2.3.0

• インスタンスメソッド

指定されたメッセージを表示します。--strict が有効な場合は例外が発生します。

指定されたメッセージを表示します。--strict が有効な場合は例外が発生します。

@param message 表示するメッセージを指定します。

@raise Gem::Exception コマンドラインオプションに --strict が指定されている場合に発生します。

• Gem::Commands::LockCommand

Gem::Commands::LockCommand#spec_path(gem_full_name) -> String (18004.0)

• 2.3.0

• インスタンスメソッド

指定された Gem パッケージの gemspec ファイルのフルパスを返します。

指定された Gem パッケージの gemspec ファイルのフルパスを返します。

@param gem_full_name Gem パッケージの名前を指定します。

• Gem::Commands::LockCommand

絞り込み条件を変える

Shell::CommandProcessor#out(dev = STDOUT, &block) -> () (9604.0)

• 2.3.0

• インスタンスメソッド

Shell#transact を呼び出しその結果を dev に出力します。

Shell#transact を呼び出しその結果を dev に出力します。

@param dev 出力先をIO オブジェクトなどで指定します。

@param block transact 内部で実行するシェルを指定します。


使用例:
require 'shell'
Shell.def_system_command("head")
sh = Shell.new
File.open("out.txt", "w"){ |fp|
sh.out(fp) {
system("ls", "-l") | head("-n 3")
}
}

• Shell::CommandProcessor

ThreadsWait#next_wait(nonblock = nil) -> Thread (9604.0)

• 2.3.0

• インスタンスメソッド

指定したスレッドのどれかが終了するまで待ちます。

指定したスレッドのどれかが終了するまで待ちます。

@param nonblock true を与えると、キューが空の時、例外 ThreadsWait::ErrNoFinishedThread が発生します。

@raise ErrNoWaitingThread 終了をまつスレッドが存在しない時、発生します。

@raise ErrNoFinishedThread nonblock がtrue でかつ、キューが空の時、発生します。

#使用例
require 'thwait'

threads = []
2.times {|i|
threads << Thread.n...

• ThreadsWait
• ThreadsWait::ErrNoFinishedThread

Shell::CommandProcessor#foreach(path = nil, &block) -> () (9304.0)

• 2.3.0

• インスタンスメソッド

pathがファイルなら, File#foreach pathがディレクトリなら, Dir#foreach の動作をします。

pathがファイルなら, File#foreach
pathがディレクトリなら, Dir#foreach
の動作をします。

@param path ファイルもしくはディレクトリのパスを文字列で指定します。

使用例
require 'shell'
Shell.verbose = false
sh = Shell.new
sh.foreach("/tmp"){|f|
puts f
}

• Shell::CommandProcessor

Thread::Queue#pop(non_block = false) -> object (9304.0)

• 2.3.0

• インスタンスメソッド

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = Queue.new

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}

t...

• Thread::Queue
• ThreadError

Thread::Queue#shift(non_block = false) -> object (9304.0)

• 2.3.0

• インスタンスメソッド

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

キューからひとつ値を取り出します。キューが空の時、呼出元のスレッドは停止します。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = Queue.new

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].each { |r|
q.push(r)
}

t...

• Thread::Queue
• ThreadError

絞り込み条件を変える

Thread::SizedQueue#enq(obj, non_block = false) -> () (9304.0)

• 2.3.0

• インスタンスメソッド

キューに与えられたオブジェクトを追加します。

キューに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与えられたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。

@see Thread::Queue#push

• Thread::SizedQueue
• ThreadError

Thread::SizedQueue#pop(non_block = false) -> object (9304.0)

• 2.3.0

• インスタンスメソッド

キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。

キューからひとつ値を取り出します。
キューに push しようと待っているスレッドがあれば、実行を再開させます。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].eac...

• Thread::SizedQueue
• ThreadError

Thread::SizedQueue#push(obj, non_block = false) -> () (9304.0)

• 2.3.0

• インスタンスメソッド

キューに与えられたオブジェクトを追加します。

キューに与えられたオブジェクトを追加します。

キューのサイズが Thread::SizedQueue#max に達している場合は、
non_block が真でなければ、キューのサイズが Thread::SizedQueue#max
より小さくなるまで他のスレッドに実行を譲ります。
その後、キューに与えられたオブジェクトを追加します。

@param obj キューに追加したいオブジェクトを指定します。
@param non_block true を与えると、キューが一杯の時に例外 ThreadError が発生します。

@see Thread::Queue#push

• Thread::SizedQueue
• ThreadError

Thread::SizedQueue#shift(non_block = false) -> object (9304.0)

• 2.3.0

• インスタンスメソッド

キューからひとつ値を取り出します。 キューに push しようと待っているスレッドがあれば、実行を再開させます。

キューからひとつ値を取り出します。
キューに push しようと待っているスレッドがあれば、実行を再開させます。

@param non_block true を与えると、キューが空の時に例外 ThreadError が発生します。

//emlist[例][ruby]{
require 'thread'

q = SizedQueue.new(4)

th1 = Thread.start do
while resource = q.pop
puts resource
end
end

[:resource1, :resource2, :resource3, nil].eac...

• Thread::SizedQueue
• ThreadError

Thread::Mutex#sleep(timeout = nil) -> Integer (9022.0)

• 2.3.0

• インスタンスメソッド

与えられた秒数の間ロックを解除してスリープして、実行後にまたロックします。

与えられた秒数の間ロックを解除してスリープして、実行後にまたロックします。

@param timeout スリープする秒数を指定します。省略するとスリープし続けます。

@return スリープしていた秒数を返します。

@raise ThreadError 自身がカレントスレッドによってロックされていない場合に発生します。

[注意] 2.0 以降ではスリープ中でも、シグナルを受信した場合などに実行が再
開(spurious wakeup)される場合がある点に注意してください。

//emlist[例][ruby]{
m = Mutex.new
th = Thread.new do
...

• Thread::Mutex

絞り込み条件を変える

Net::FTP#get(remotefile, localfile = File.basename(remotefile), blocksize = DEFAULT_BLOCKSIZE) -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバ上のファイルを取得します。

サーバ上のファイルを取得します。

Net::FTP#binary の値に従って
Net::FTP#getbinaryfile もしくは
Net::FTP#gettextfile を呼びだします。

binary が偽のとき、つまりテキストモードの
ときには blocksize は無視されます。

@param remotefile 取得対象のリモートのファイル名を与えます。
@param localfile 取得したデータを格納するローカルのファイル名を与えます。
@param blocksize データ転送の単位をバイト単位で与えます。

@raise Net::FTPTempError...

• Net::FTP

Net::FTP#get(remotefile, localfile = File.basename(remotefile), blocksize = DEFAULT_BLOCKSIZE) { |data| .... } -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバ上のファイルを取得します。

サーバ上のファイルを取得します。

Net::FTP#binary の値に従って
Net::FTP#getbinaryfile もしくは
Net::FTP#gettextfile を呼びだします。

binary が偽のとき、つまりテキストモードの
ときには blocksize は無視されます。

@param remotefile 取得対象のリモートのファイル名を与えます。
@param localfile 取得したデータを格納するローカルのファイル名を与えます。
@param blocksize データ転送の単位をバイト単位で与えます。

@raise Net::FTPTempError...

• Net::FTP

Net::FTP#getbinaryfile(remotefile, localfile = File.basename(remotefile), blocksize = DEFAULT_BLOCKSIZE) -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバ上のファイルをバイナリモードで取得します。

サーバ上のファイルをバイナリモードで取得します。

サーバー上にある remotefile という名前のファイルを取得し、
ローカルの localfile という名前のファイルに保存します。

localfile が nil である場合には保存はしません。

データの転送は blocksize バイト毎に行なわれます。

ブロックが指定された場合は
データを blocksize バイト受信するごとに、そのデータを
ブロックに渡します。

@param remotefile 取得対象のリモートのファイル名を与えます。
@param localfile 取得したデータを格納するローカルのファイル...

• Net::FTP

Net::FTP#getbinaryfile(remotefile, localfile = File.basename(remotefile), blocksize = DEFAULT_BLOCKSIZE) {|data| ...} -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバ上のファイルをバイナリモードで取得します。

サーバ上のファイルをバイナリモードで取得します。

サーバー上にある remotefile という名前のファイルを取得し、
ローカルの localfile という名前のファイルに保存します。

localfile が nil である場合には保存はしません。

データの転送は blocksize バイト毎に行なわれます。

ブロックが指定された場合は
データを blocksize バイト受信するごとに、そのデータを
ブロックに渡します。

@param remotefile 取得対象のリモートのファイル名を与えます。
@param localfile 取得したデータを格納するローカルのファイル...

• Net::FTP

Net::FTP#put(localfile, remotefile = File.basename(localfile), blocksize = DEFAULT_BLOCKSIZE) -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバへファイルを転送します。

サーバへファイルを転送します。

Net::FTP#binary の値に従って
Net::FTP#putbinaryfile もしくは
Net::FTP#puttextfile を呼びだします。

binary が偽のとき、つまりテキストモードの
ときには blocksize は無視されます。

@param localfile 転送するローカルのファイル名を与えます。
@param remotefile 転送データを保存するリモートのファイル名を与えます。
@param blocksize データ転送の単位をバイト単位で与えます。

@raise Net::FTPTempError 応答コ...

• Net::FTP

絞り込み条件を変える

Net::FTP#put(localfile, remotefile = File.basename(localfile), blocksize = DEFAULT_BLOCKSIZE) { |data| .... } -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバへファイルを転送します。

サーバへファイルを転送します。

Net::FTP#binary の値に従って
Net::FTP#putbinaryfile もしくは
Net::FTP#puttextfile を呼びだします。

binary が偽のとき、つまりテキストモードの
ときには blocksize は無視されます。

@param localfile 転送するローカルのファイル名を与えます。
@param remotefile 転送データを保存するリモートのファイル名を与えます。
@param blocksize データ転送の単位をバイト単位で与えます。

@raise Net::FTPTempError 応答コ...

• Net::FTP

Net::FTP#putbinaryfile(localfile, remotefile = File.basename(localfile), blocksize = DEFAULT_BLOCKSIZE) -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバにファイルをバイナリモードで転送します。

サーバにファイルをバイナリモードで転送します。

ローカルの localfile という名前のファイルを読みだし、
サーバー上の remotefile という名前のファイルに保存します。

データの転送は blocksize バイト毎に行なわれます。

ブロックが指定された場合は
データを blocksize バイト転送するごとに、そのデータを
ブロックに渡します。

@param localfile 転送するローカルのファイル名を与えます。
@param remotefile 転送データを保存するリモートのファイル名を与えます。
@param blocksize データ転送の単位をバイト単...

• Net::FTP

Net::FTP#putbinaryfile(localfile, remotefile = File.basename(localfile), blocksize = DEFAULT_BLOCKSIZE) {|data| ...} -> nil (904.0)

• 2.3.0

• インスタンスメソッド

サーバにファイルをバイナリモードで転送します。

サーバにファイルをバイナリモードで転送します。

ローカルの localfile という名前のファイルを読みだし、
サーバー上の remotefile という名前のファイルに保存します。

データの転送は blocksize バイト毎に行なわれます。

ブロックが指定された場合は
データを blocksize バイト転送するごとに、そのデータを
ブロックに渡します。

@param localfile 転送するローカルのファイル名を与えます。
@param remotefile 転送データを保存するリモートのファイル名を与えます。
@param blocksize データ転送の単位をバイト単...

• Net::FTP

Enumerator::Lazy#enum_for(method = :each, *args) {|*args| block} -> Enumerator::Lazy (604.0)

• 2.3.0

• インスタンスメソッド

Object#to_enum と同じですが、Enumerator::Lazy を返します。

Object#to_enum と同じですが、Enumerator::Lazy を返します。

to_enum は「ブロック付きで呼ぶとループを実行し、ブロックを省略した場合は
Enumerator を返す」ようなメソッドを定義するときによく使われます。
このときに lazy 性が正しく引き継がれるように、Lazy#to_enum は
素のEnumerator ではなく Enumerator::Lazy を返すようになっています。

//emlist[例][ruby]{
module Enumerable
# 要素をn回ずつ繰り返すメソッド
# 例：[1,2,3].repeat(2) ...

• Enumerator::Lazy

Enumerator::Lazy#to_enum(method = :each, *args) {|*args| block} -> Enumerator::Lazy (604.0)

• 2.3.0

• インスタンスメソッド

Object#to_enum と同じですが、Enumerator::Lazy を返します。

Object#to_enum と同じですが、Enumerator::Lazy を返します。

to_enum は「ブロック付きで呼ぶとループを実行し、ブロックを省略した場合は
Enumerator を返す」ようなメソッドを定義するときによく使われます。
このときに lazy 性が正しく引き継がれるように、Lazy#to_enum は
素のEnumerator ではなく Enumerator::Lazy を返すようになっています。

//emlist[例][ruby]{
module Enumerable
# 要素をn回ずつ繰り返すメソッド
# 例：[1,2,3].repeat(2) ...

• Enumerator::Lazy

絞り込み条件を変える

Net::FTP#retrbinary(cmd, blocksize, rest_offset = nil) -> nil (604.0)

• 2.3.0

• インスタンスメソッド

サーバーに cmd で指定されたコマンドを送り、バイナリデータを 取り寄せます。

サーバーに cmd で指定されたコマンドを送り、バイナリデータを
取り寄せます。

blocksize で指定されたバイト単位でデータを
読み込み、ブロックに渡します。

rest_offset が省略されなかった場合は、cmdを送る前に
REST コマンドを送り、指定したバイト数の位置から
転送を開始します。

@param cmd コマンドを文字列で与えます。
@param blocksize 読み込み単位をバイト単位で与えます。
@param rest_offset REST コマンドに与えるオフセットを与えます。

@raise Net::FTPTempError 応答コードが 4...

• Net::FTP

Net::FTP#retrbinary(cmd, blocksize, rest_offset = nil) {|data| ...} -> nil (604.0)

• 2.3.0

• インスタンスメソッド

サーバーに cmd で指定されたコマンドを送り、バイナリデータを 取り寄せます。

サーバーに cmd で指定されたコマンドを送り、バイナリデータを
取り寄せます。

blocksize で指定されたバイト単位でデータを
読み込み、ブロックに渡します。

rest_offset が省略されなかった場合は、cmdを送る前に
REST コマンドを送り、指定したバイト数の位置から
転送を開始します。

@param cmd コマンドを文字列で与えます。
@param blocksize 読み込み単位をバイト単位で与えます。
@param rest_offset REST コマンドに与えるオフセットを与えます。

@raise Net::FTPTempError 応答コードが 4...

• Net::FTP

Net::FTP#storbinary(cmd, file, blocksize, rest_offset = nil) -> nil (604.0)

• 2.3.0

• インスタンスメソッド

サーバーに cmd で指定されたコマンドを送り、バイナリデータを 送ります。

サーバーに cmd で指定されたコマンドを送り、バイナリデータを
送ります。

送るデータは IO のインスタンスを
file で指定します。
(実際には StringIO のような IO とメソッドレベルで
互換するオブジェクトであればなんでもかまいません)。

blocksize で指定されたバイト単位で file からデータを読みこみ、
サーバに送ります。

rest_offset が省略されなかった場合は、cmdを送る前に
REST コマンドを送り、指定したバイト数の位置から
転送を開始します。

ブロックが指定された場合には、転送するデータを blocksize ごとに
ブロックに...

• IO
• Net::FTP
• StringIO

Net::FTP#storbinary(cmd, file, blocksize, rest_offset = nil) {|data| ...} -> nil (604.0)

• 2.3.0

• インスタンスメソッド

サーバーに cmd で指定されたコマンドを送り、バイナリデータを 送ります。

サーバーに cmd で指定されたコマンドを送り、バイナリデータを
送ります。

送るデータは IO のインスタンスを
file で指定します。
(実際には StringIO のような IO とメソッドレベルで
互換するオブジェクトであればなんでもかまいません)。

blocksize で指定されたバイト単位で file からデータを読みこみ、
サーバに送ります。

rest_offset が省略されなかった場合は、cmdを送る前に
REST コマンドを送り、指定したバイト数の位置から
転送を開始します。

ブロックが指定された場合には、転送するデータを blocksize ごとに
ブロックに...

• IO
• Net::FTP
• StringIO

Shell#out(dev = STDOUT, &block) -> () (604.0)

• 2.3.0

• インスタンスメソッド

Shell#transact を呼び出しその結果を dev に出力します。

Shell#transact を呼び出しその結果を dev に出力します。

@param dev 出力先をIO オブジェクトなどで指定します。

@param block transact 内部で実行するシェルを指定します。


使用例:
require 'shell'
Shell.def_system_command("head")
sh = Shell.new
File.open("out.txt", "w"){ |fp|
sh.out(fp) {
system("ls", "-l") | head("-n 3")
}
}

• Shell

絞り込み条件を変える

Shell::Filter#out(dev = STDOUT, &block) -> () (604.0)

• 2.3.0

• インスタンスメソッド

Shell#transact を呼び出しその結果を dev に出力します。

Shell#transact を呼び出しその結果を dev に出力します。

@param dev 出力先をIO オブジェクトなどで指定します。

@param block transact 内部で実行するシェルを指定します。


使用例:
require 'shell'
Shell.def_system_command("head")
sh = Shell.new
File.open("out.txt", "w"){ |fp|
sh.out(fp) {
system("ls", "-l") | head("-n 3")
}
}

• Shell::Filter

Array#select! {|item| block } -> self | nil (340.0)

• 2.3.0

• インスタンスメソッド

ブロックが真を返した要素を残し、偽を返した要素を自身から削除します。 変更があった場合は self を、 変更がなかった場合には nil を返します。

ブロックが真を返した要素を残し、偽を返した要素を自身から削除します。
変更があった場合は self を、
変更がなかった場合には nil を返します。

//emlist[例][ruby]{
a = %w{ a b c d e f }
a.select! {|v| v =~ /[a-z]/ } # => nil
a # => ["a", "b", "c", "d", "e", "f"]
//}

ブロックが与えられなかった場合は、自身と select! から生成した
Enumerator オブジェクトを返します。

@see Array#keep_if, Array#reject!

• Array
• Enumerator