Elixir v1.5.0 Process View Source
Conveniences for working with processes and the process dictionary.
Besides the functions available in this module, the Kernel module
exposes and auto-imports some basic functionality related to processes
available through the following functions:
Link to this section Summary
Functions
Tells whether the given process is alive
Cancels a timer returned by send_after/3
Deletes the given key from the process dictionary
Demonitors the monitor identifies by the given reference
Sends an exit signal with the given reason to pid
Sets the given flag to value for the calling process
Sets the given flag to value for the given process pid
Returns all key-value pairs in the process dictionary
Returns the value for the given key in the process dictionary,
or default if key is not set
Returns all keys in the process dictionary
Returns all keys in the process dictionary that have the given value
Returns the PID of the group leader for the calling process
Sets the group leader of the given pid to leader
Puts the calling process into a “hibernation” state
Returns information about the process identified by pid, or returns nil if the process
is not alive
Returns information about the process identified by pid,
or returns nil if the process is not alive
Creates a link between the calling process and the given item (process or port)
Returns a list of PIDs corresponding to all the processes currently existing on the local node
Starts monitoring the given item from the calling process
Stores the given key-value pair in the process dictionary
Reads a timer created by send_after/3
Registers the given pid_or_port under the given name
Returns a list of names which have been registered using register/2
Sends a message to the given process
Sends msg to dest after time milliseconds
Sleeps the current process for the given timeout
Spawns the given function according to the given options
Spawns the given function fun from module mod, passing the given args
according to the given options
Removes the link between the calling process and the given item (process or port)
Removes the registered name, associated with a PID
or a port identifier
Returns the PID or port identifier registered under name or nil if the
name is not registered
Link to this section Types
spawn_opt() :: :link | :monitor | {:priority, :low | :normal | :high} | {:fullsweep_after, non_neg_integer()} | {:min_heap_size, non_neg_integer()} | {:min_bin_vheap_size, non_neg_integer()}
Link to this section Functions
Tells whether the given process is alive.
If the process identified by pid is alive (that is, it’s not exiting and has
not exited yet) than this function returns true. Otherwise, it returns
false.
pid must refer to a process running on the local node.
Inlined by the compiler.
cancel_timer(reference(), options) :: non_neg_integer() | false | :ok when options: [async: boolean(), info: boolean()]
Cancels a timer returned by send_after/3.
When the result is an integer, it represents the time in milliseconds left until the timer would have expired.
When the result is false, a timer corresponding to timer_ref could not be
found. This can happen either because the timer expired, because it has
already been canceled, or because timer_ref never corresponded to a timer.
Even if the timer had expired and the message was sent, this function does not tell you if the timeout message has arrived at its destination yet.
Options
:async- (boolean) whenfalse, the request for cancellation is synchronous. Whentrue, the request for cancellation is asynchronous, meaning that the request to cancel the timer is issued and:okis returned right away. Defaults tofalse.:info- (boolean) whether to return information about the timer being cancelled. When the:asyncoption isfalseand:infoistrue, then either an integer orfalse(like described above) is returned. If:asyncisfalseand:infoisfalse,:okis returned. If:asyncistrueand:infoistrue, a message in the form{:cancel_timer, timer_ref, result}(whereresultis an integer orfalselike described above) is sent to the caller of this function when the cancellation has been performed. If:asyncistrueand:infoisfalse, no message is sent. Defaults totrue.
Inlined by the compiler.
Deletes the given key from the process dictionary.
Returns the value that was under key in the process dictionary,
or nil if key was not stored in the process dictionary.
Examples
Process.put(:comments, ["comment", "other comment"])
Process.delete(:comments)
#=> ["comment", "other comment"]
Process.delete(:comments)
#=> nil
Demonitors the monitor identifies by the given reference.
If monitor_ref is a reference which the calling process
obtained by calling monitor/1, that monitoring is turned off.
If the monitoring is already turned off, nothing happens.
See :erlang.demonitor/2 for more info.
Inlined by the compiler.
Sends an exit signal with the given reason to pid.
The following behaviour applies if reason is any term except :normal
or :kill:
If
pidis not trapping exits,pidwill exit with the givenreason.If
pidis trapping exits, the exit signal is transformed into a message{:EXIT, from, reason}and delivered to the message queue ofpid.
If reason is the atom :normal, pid will not exit (unless pid is
the calling process, in which case it will exit with the reason :normal).
If it is trapping exits, the exit signal is transformed into a message
{:EXIT, from, :normal} and delivered to its message queue.
If reason is the atom :kill, that is if Process.exit(pid, :kill) is called,
an untrappable exit signal is sent to pid which will unconditionally exit
with reason :killed.
Inlined by the compiler.
Examples
Process.exit(pid, :kill)
#=> true
flag(:trap_exit, boolean()) :: boolean()
flag(:sensitive, boolean()) :: boolean()
flag(:save_calls, 0..10000) :: 0..10000
flag(:priority, priority_level()) :: priority_level()
flag({:monitor_nodes, term()}, term()) :: term()
flag(:monitor_nodes, term()) :: term()
flag(:min_heap_size, non_neg_integer()) :: non_neg_integer()
flag(:min_bin_vheap_size, non_neg_integer()) :: non_neg_integer()
flag(:message_queue_data, :erlang.message_queue_data()) :: :erlang.message_queue_data()
flag(:max_heap_size, heap_size()) :: heap_size()
flag(:error_handler, module()) :: module()
Sets the given flag to value for the calling process.
Returns the old value of flag.
See :erlang.process_flag/2 for more info.
Note that flag values :max_heap_size and :message_queue_data are only available since OTP 19.
Inlined by the compiler.
flag(pid(), :save_calls, 0..10000) :: 0..10000
Sets the given flag to value for the given process pid.
Returns the old value of flag.
It raises ArgumentError if pid is not a local process.
The allowed values for flag are only a subset of those allowed in flag/2,
namely :save_calls.
See :erlang.process_flag/3 for more info.
Inlined by the compiler.
Returns all key-value pairs in the process dictionary.
Inlined by the compiler.
Returns the value for the given key in the process dictionary,
or default if key is not set.
Returns all keys in the process dictionary.
Inlined by the compiler.
Returns all keys in the process dictionary that have the given value.
Inlined by the compiler.
Returns the PID of the group leader for the calling process.
Inlined by the compiler.
Sets the group leader of the given pid to leader.
Typically, this is used when a process started from a certain shell should
have a group leader other than :init.
Inlined by the compiler.
Puts the calling process into a “hibernation” state.
The calling process is put into a waiting state where its memory allocation has been reduced as much as possible, which is useful if the process does not expect to receive any messages in the near future.
See :erlang.hibernate/3 for more info.
Inlined by the compiler.
Returns information about the process identified by pid, or returns nil if the process
is not alive.
Use this only for debugging information.
See :erlang.process_info/1 for more info.
Returns information about the process identified by pid,
or returns nil if the process is not alive.
See :erlang.process_info/2 for more info.
Creates a link between the calling process and the given item (process or port).
Links are bidirectional. Linked processes can be unlinked by using unlink/1.
If such a link exists already, this function does nothing since there can only be one link between two given processes. If a process tries to create a link to itself, nothing will happen.
When two processes are linked, each one receives exit signals from the other
(see also exit/2). Let’s assume pid1 and pid2 are linked. If pid2
exits with a reason other than :normal (which is also the exit reason used
when a process finishes its job) and pid1 is not trapping exits (see
flag/2), then pid1 will exit with the same reason as pid2 and in turn
emit an exit signal to all its other linked processes. The behaviour when
pid1 is trapping exits is described in exit/2.
See :erlang.link/1 for more info.
Inlined by the compiler.
Returns a list of PIDs corresponding to all the processes currently existing on the local node.
Note that if a process is exiting, it is considered to exist but not be
alive. This means that for such process, alive?/1 will return false but
its PID will be part of the list of PIDs returned by this function.
See :erlang.processes/0 for more info.
Inlined by the compiler.
Starts monitoring the given item from the calling process.
Once the monitored process dies, a message is delivered to the monitoring process in the shape of:
{:DOWN, ref, :process, object, reason}
where:
refis a monitor reference returned by this function;objectis either apidof the monitored process (if monitoring a PID) or{name, node}(if monitoring a remote or local name);reasonis the exit reason.
See the need for monitoring
for an example.
See :erlang.monitor/2 for more info.
Inlined by the compiler.
Stores the given key-value pair in the process dictionary.
The return value of this function is the value that was previously stored
under key, or nil in case no value was stored under key.
Examples
# Assuming :locale was not set
Process.put(:locale, "en")
#=> nil
Process.put(:locale, "fr")
#=> "en"
read_timer(reference()) :: non_neg_integer() | false
Reads a timer created by send_after/3.
When the result is an integer, it represents the time in milliseconds left until the timer will expire.
When the result is false, a timer corresponding to timer_ref could not be
found. This can be either because the timer expired, because it has already
been canceled, or because timer_ref never corresponded to a timer.
Even if the timer had expired and the message was sent, this function does not tell you if the timeout message has arrived at its destination yet.
Inlined by the compiler.
Registers the given pid_or_port under the given name.
name must be an atom and can then be used instead of the
PID/port identifier when sending messages with Kernel.send/2.
register/2 will fail with ArgumentError in any of the following cases:
- the PID/Port is not existing locally and alive
- the name is already registered
- the
pid_or_portis already registered under a differentname
The following names are reserved and cannot be assigned to processes nor ports:
nilfalsetrue:undefined
Returns a list of names which have been registered using register/2.
Inlined by the compiler.
Sends a message to the given process.
Options
:noconnect- when used, if sending the message would require an auto-connection to another node the message is not sent and:noconnectis returned.:nosuspend- when used, if sending the message would cause the sender to be suspended the message is not sent and:nosuspendis returned.
Otherwise the message is sent and :ok is returned.
Examples
iex> Process.send({:name, :node_that_does_not_exist}, :hi, [:noconnect])
:noconnect
Inlined by the compiler.
Sends msg to dest after time milliseconds.
If dest is a PID, it must be the PID of a local process, dead or alive.
If dest is an atom, it must be the name of a registered process
which is looked up at the time of delivery. No error is produced if the name does
not refer to a process.
This function returns a timer reference, which can be read with read_timer/1
or canceled with cancel_timer/1.
The timer will be automatically canceled if the given dest is a PID
which is not alive or when the given PID exits. Note that timers will not be
automatically canceled when dest is an atom (as the atom resolution is done
on delivery).
Inlined by the compiler.
Options
:abs- (boolean) whenfalse,timeis treated as relative to the current monotonic time. Whentrue,timeis the absolute value of the Erlang monotonic time at whichmsgshould be delivered todest. To read more about Erlang monotonic time and other time-related concepts, look at the documentation for theSystemmodule. Defaults tofalse.
Examples
timer_ref = Process.send_after(pid, :hi, 1000)
Sleeps the current process for the given timeout.
timeout is either the number of milliseconds to sleep as an
integer or the atom :infinity. When :infinity is given,
the current process will sleep forever, and not
consume or reply to messages.
Use this function with extreme care. For almost all situations
where you would use sleep/1 in Elixir, there is likely a
more correct, faster and precise way of achieving the same with
message passing.
For example, if you are waiting for a process to perform some action, it is better to communicate the progress of such action with messages.
In other words, do not:
Task.start_link fn ->
do_something()
...
end
# Wait until work is done
Process.sleep(2000)
But do:
parent = self()
Task.start_link fn ->
do_something()
send parent, :work_is_done
...
end
receive do
:work_is_done -> :ok
after
30_000 -> :timeout # Optional timeout
end
For cases like the one above, Task.async/1 and Task.await/2 are
preferred.
Similarly, if you are waiting for a process to terminate, monitor that process instead of sleeping. Do not:
Task.start_link fn ->
...
end
# Wait until task terminates
Process.sleep(2000)
Instead do:
{:ok, pid} =
Task.start_link fn ->
...
end
ref = Process.monitor(pid)
receive do
{:DOWN, ^ref, _, _, _} -> :task_is_down
after
30_000 -> :timeout # Optional timeout
end
spawn((() -> any()), spawn_opts()) :: pid() | {pid(), reference()}
Spawns the given function according to the given options.
The result depends on the given options. In particular,
if :monitor is given as an option, it will return a tuple
containing the PID and the monitoring reference, otherwise
just the spawned process PID.
More options are available; for the comprehensive list of available options
check :erlang.spawn_opt/4.
Inlined by the compiler.
Spawns the given function fun from module mod, passing the given args
according to the given options.
The result depends on the given options. In particular,
if :monitor is given as an option, it will return a tuple
containing the PID and the monitoring reference, otherwise
just the spawned process PID.
It also accepts extra options, for the list of available options
check :erlang.spawn_opt/4.
Inlined by the compiler.
Removes the link between the calling process and the given item (process or port).
If there is no such link, this function does nothing. If pid_or_port does
not exist, this function does not produce any errors and simply does nothing.
The return value of this function is always true.
See :erlang.unlink/1 for more info.
Inlined by the compiler.
Removes the registered name, associated with a PID
or a port identifier.
Fails with ArgumentError if the name is not registered
to any PID or port.
Inlined by the compiler.
Returns the PID or port identifier registered under name or nil if the
name is not registered.
See :erlang.whereis/1 for more info.