383件ヒット
[301-383件を表示]
(0.056秒)
クラス
- IO (88)
- Mutex (2)
- PStore (11)
- Socket (44)
- Thread (126)
-
Thread
:: ConditionVariable (11) -
Thread
:: Mutex (9) -
Thread
:: Queue (14) -
Thread
:: SizedQueue (11) - ThreadGroup (11)
- ThreadsWait (18)
- TracePoint (11)
-
YAML
:: Store (16)
モジュール
- Rake (11)
キーワード
-
abort
_ on _ exception= (11) -
all
_ waits (12) - application= (11)
-
handle
_ interrupt (11) - kill (11)
- list (11)
- new (113)
-
pending
_ interrupt? (11) - pipe (88)
-
report
_ on _ exception (8) -
report
_ on _ exception= (8) - start (11)
- stop (11)
-
tcp
_ server _ loop (22) - unix (22)
検索結果
先頭5件
-
IO
. pipe(ext _ enc) {|read _ io , write _ io| . . . } -> object (19.0) -
pipe(2) を実行して、相互につながった2つの IO オブジェクトを要素とする配列を返します。
...グなどを設定するキーワード引数(see IO.new)
@raise Errno::EXXX IO オブジェクトの作成に失敗した場合に発生します。
r, w = IO.pipe
p [r, w] # => [#<IO:0x401b90f8>, #<IO:0x401b7718>]
Thread.new do
w.puts "foo"
w.close
end
p r.gets... -
IO
. pipe(ext _ enc , int _ enc , **opts) -> [IO] (19.0) -
pipe(2) を実行して、相互につながった2つの IO オブジェクトを要素とする配列を返します。
...グなどを設定するキーワード引数(see IO.new)
@raise Errno::EXXX IO オブジェクトの作成に失敗した場合に発生します。
r, w = IO.pipe
p [r, w] # => [#<IO:0x401b90f8>, #<IO:0x401b7718>]
Thread.new do
w.puts "foo"
w.close
end
p r.gets... -
IO
. pipe(ext _ enc , int _ enc , **opts) {|read _ io , write _ io| . . . } -> object (19.0) -
pipe(2) を実行して、相互につながった2つの IO オブジェクトを要素とする配列を返します。
...グなどを設定するキーワード引数(see IO.new)
@raise Errno::EXXX IO オブジェクトの作成に失敗した場合に発生します。
r, w = IO.pipe
p [r, w] # => [#<IO:0x401b90f8>, #<IO:0x401b7718>]
Thread.new do
w.puts "foo"
w.close
end
p r.gets... -
Rake
. application=(app) (13.0) -
現在の Rake アプリケーションをセットします。
...//emlist[][ruby]{
# Rakefile での記載例とする
require 'pp'
task default: :test_rake_app
task :test_rake_app do
app = Rake::Application.new
app.tty_output = true
Rake.application = app
pp Rake.application
end
# => #<Rake::Application:0x00005624e6c30eb8
# @default_loader=#<Rak......rakelib=["rakelib"], show_all_tasks=false, show_prereqs=false, show_task_pattern=nil, show_tasks=nil, silent=false, suppress_backtrace_pattern=nil, thread_pool_size=20, trace=false, trace_output=#<IO:<STDERR>>, trace_rules=false>,
# @original_dir="/path/to/dir",
# @pending_imports=[],
#... -
Socket
. tcp _ server _ loop(host , port) {|sock , addr| . . . } -> () (13.0) -
TCP/IP で host:port で待ち受けるサーバ側のソケットを作成し、 新しい接続を受け入れるごとにブロックを呼び出します。
...限がない(つまり接続過剰になりえる)ことに注意
require 'socket'
Socket.tcp_server_loop(16807) {|sock, client_addrinfo|
Thread.new {
begin
IO.copy_stream(sock, sock)
ensure
sock.close
end
}
}
内部的には Socket.tcp_server_socket... -
Socket
. tcp _ server _ loop(port) {|sock , addr| . . . } -> () (13.0) -
TCP/IP で host:port で待ち受けるサーバ側のソケットを作成し、 新しい接続を受け入れるごとにブロックを呼び出します。
...限がない(つまり接続過剰になりえる)ことに注意
require 'socket'
Socket.tcp_server_loop(16807) {|sock, client_addrinfo|
Thread.new {
begin
IO.copy_stream(sock, sock)
ensure
sock.close
end
}
}
内部的には Socket.tcp_server_socket... -
Socket
. unix(path) -> Socket (13.0) -
Unix クライアントソケットを生成します。
...ブロックの終了後に
ソケットを IO#close します。
require 'socket'
# /tmp/sock と通信する
Socket.unix("/tmp/sock") {|sock|
t = Thread.new { IO.copy_stream(sock, STDOUT) }
IO.copy_stream(STDIN, sock)
t.join
}
@param path 接続対象のパス(文字列)... -
Socket
. unix(path) {|sock| . . . } -> object (13.0) -
Unix クライアントソケットを生成します。
...ブロックの終了後に
ソケットを IO#close します。
require 'socket'
# /tmp/sock と通信する
Socket.unix("/tmp/sock") {|sock|
t = Thread.new { IO.copy_stream(sock, STDOUT) }
IO.copy_stream(STDIN, sock)
t.join
}
@param path 接続対象のパス(文字列)...