Elixir GenServer并行handle_call
Elixir GenServer是Elixir语言中的一个并发编程模型，用于构建可扩展和可靠的并发系统。GenServer是Elixir中的一个抽象层，它提供了一种简单而强大的方式来管理状态和处理并发请求。
GenServer的主要作用是处理来自其他进程的请求，并维护自己的状态。它可以处理两种类型的请求：handle_call和handle_cast。在这里，我们将重点关注handle_call。
handle_call是GenServer中用于处理同步请求的函数。当其他进程向GenServer发送一个请求时，GenServer会调用handle_call函数来处理该请求，并返回一个响应。handle_call函数的签名如下：
def handle_call(request, from, state) do
# 处理请求的逻辑
{:reply, response, new_state}
end其中，request是接收到的请求，from是请求的发送者进程的PID，state是GenServer的当前状态。handle_call函数需要返回一个三元组，包含响应的类型（:reply）、响应的内容（response）以及更新后的状态（new_state）。
Elixir GenServer的并行处理能力使得它非常适合构建高并发的应用程序。通过使用多个GenServer实例，可以实现请求的并行处理，提高系统的吞吐量和响应速度。
以下是一些Elixir GenServer的优势和应用场景：
优势：
- 并发处理：GenServer提供了一种简单而强大的方式来处理并发请求，使得系统能够高效地处理大量的并发操作。
- 可靠性：GenServer提供了一些机制来处理异常情况，例如超时、进程崩溃等，从而提高系统的可靠性。
- 可扩展性：通过使用多个GenServer实例，可以实现系统的水平扩展，以应对不断增长的请求量。
应用场景：
- 实时聊天应用：GenServer可以用于处理用户之间的聊天消息，保证消息的有序处理和可靠传递。
- 游戏服务器：GenServer可以用于处理玩家之间的交互请求，例如玩家之间的对战、交易等操作。
- 分布式任务调度：通过使用多个GenServer实例，可以实现分布式任务调度系统，提高任务的并行处理能力。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 腾讯云云原生容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云数据库（TencentDB）：https://cloud.tencent.com/product/cdb
- 腾讯云人工智能（AI）：https://cloud.tencent.com/product/ai
- 腾讯云物联网（IoT）：https://cloud.tencent.com/product/iot
- 腾讯云移动开发（移动推送、移动分析等）：https://cloud.tencent.com/product/mobile
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云区块链（BCS）：https://cloud.tencent.com/product/bcs
- 腾讯云元宇宙（Tencent XR）：https://cloud.tencent.com/product/xr
请注意，以上链接仅供参考，具体的产品选择应根据实际需求进行评估和决策。
相关·内容
我正在尝试搜索存储在genserver中的键值对。对于如何将映射传递到handle_call函数，我认为我的语法有问题。 这是我的搜索函数和处理回调函数： def search(bucket, key_value_list) do
Enum.map(key_value_list, fn {key, value} ->
GenServer.call(bucket, {:search, key_value_list})
end)
end
def handle_call({:search, key_value_list}, from, state) do
{:nore
浏览 14提问于2020-01-24得票数 1
回答已采纳
在elixir GenServer中，有同步和异步方法，handle_cast和handle_call。在异步的情况下，如果方法失败了，如何获取通知？
方法失败意味着在handle_call方法中，我需要定义一些逻辑来查询/写入数据库。如果数据库操作失败，我需要将此失败通知调用者。在异步方法中，我如何做到这一点？
浏览 13提问于2018-02-11得票数 3
回答已采纳
我在一个名为GenServer的模块中有一个CameraServer，它获取图像，然后由菲尼克斯应用程序中的某些端点使用。
defmodule MyApp.CameraServer do
@name :image_server
use GenServer
def start_link(_opts) do
IO.puts("Starting image server")
GenServer.start(__MODULE__, [], name: @name)
IO.puts("Image server started")
浏览 3提问于2022-10-12得票数 0
回答已采纳
1回答
我正在从genserver中的handle函数调用长生不老药来添加电话号码获取表单客户端。但是一旦handle_call被调用，所有者进程就会崩溃，超时。请帮帮忙。
一个ETS是全局创建的，用于在调用以下任何指定函数之前插入已经存在的值。
def handle_info(message, state) do
{a,b} = message
phonenumber = b[:body]
add phonenumber
{:noreply, state}
end
def add(phonenumber) do
GenServer.call(__MODU
浏览 1提问于2014-08-08得票数 8
回答已采纳
我有一个问题，凤凰应用程序是部署在heroku上。当我在本地运行这段代码时，一切正常，没有错误。当部署到heroku时，应用程序成功地部署和启动，但是当使用应用程序GenServer时，进程会崩溃，导致以下错误：
[error] GenServer :main_worker terminating
** (exit) an exception was raised:
** (ErlangError) erlang error: :"function not exported"
(elixir) Map.get_and_update!(%{"locat
浏览 3提问于2016-01-06得票数 1
回答已采纳
1回答
我正在学习Elixir，并决定使用GenServer和工人来编写一个示例应用程序来查找素数。
应用程序
设置
我创建了我的应用程序如下：
$ mix new primes
$ cd primes
结构
$ tree lib
lib/
├── prime_numbers.ex
├── prime_server.ex
└── prime_worker.ex
lib/prime_numbers.ex
这是执行实际逻辑以确定给定数字是否为素数(is_prime/1)的模块：
defmodule PrimeNumbers do
def is_prime(x) when is_number(x) an
浏览 6提问于2022-03-13得票数 2
如果我的GenStage的handle_demand/2方法如下所示：
def handle_demand(demand, _state) when demand > 0 do
case Queue.dequeue do
nil ->
Logger.debug("Queue empty.")
{:noreply, [], []}
{job, updated_queue} -> {:noreply, job, updated_queue}
end
end
当我的Queue ( GenServer)被更改/更新时，如
浏览 5提问于2017-09-28得票数 0
回答已采纳
我有两个GenServer模块-A和B.B监视器A，并实现handle_info在A崩溃时接收:DOWN消息。
在我的示例代码中，B向A发出同步请求(handle_call)，同时处理请求时，A崩溃。B应该接收:DOWN消息，但它没有。为什么？
当我用handle_call代替handle_cast时，B收到了:DOWN消息。你能告诉我为什么handle_call不工作，而handle_cast不工作吗？
以下是简单的示例代码：
defmodule A do
use GenServer
def start_link do
GenServer.start_link(__MODU
浏览 2提问于2017-08-28得票数 1
回答已采纳
我一直在学习Elixir，并试图构建一个类似于火星漫游者Kata的应用程序 我使用GenServer来维护单个漫游者的状态，在注册表的帮助下，我尝试生成一个密钥，即漫游者名称 Rover.ex代码 defstruct [:x, :y, :direction, :name]
def start_link({x, y, d, name}) do
GenServer.start_link(__MODULE__, {x, y, d, name}, name: RegistryHelper.create_key(name))
end
def init({x, y, d, n
浏览 14提问于2019-05-08得票数 1
回答已采纳
我的代码如下：
def ping(servoId) do
Utilities.check_integer!(servoId,0,1,Error.const_error_servo_id())
Genserver.call(@name,{:ping,servoId})
end
编译器不提供错误消息。但是在运行时，消息如下，为什么？：
iex(3)> Mechanics.Servo.ping(1)
03:41:01.629 [error] Loading of /Users/yuchen/homebrew/Cellar/elixir/1.13.4/bin/../li
浏览 3提问于2022-07-24得票数 1
回答已采纳
GenServer handle_call/3实现可以返回:continue来调用其他函数。对于此函数何时相对于其他消息运行，是否有任何保证？
例如，假设这个模块只保留一个运行计数器：
defmodule Tmp do
use GenServer
def start_link(opts), do: GenServer.start_link(__MODULE__, 0, opts)
def incr(tmp), do: GenServer.call(tmp, :incr)
@impl true
def init(state), do: {:ok, state}
@i
浏览 14提问于2022-03-10得票数 2
回答已采纳
我有一个工作的GenServer和工作主管。如果我启动监督程序，GenServer就会启动。如果GenServer被杀死，主管将重新启动它。
我现在正尝试将我的代码作为一个“应用程序”启动。为此，我正在更改mix.exs文件中的代码。
我的全部代码在下面。我得到的误差在最下面。
todos/lib/todos.exs
defmodule App.Service do
use GenServer
def start_link(state) do
GenServer.start_link(__MODULE__, state, name: __MODULE__)
end
浏览 5提问于2022-10-24得票数 0
1回答
似乎奇怪的是，国家必须一直被传递。State模块不能保持自身，所以我可以做一些类似的事情
state = %State{size: size}
case state.is_full? do
...
在这里，州总是通过的。我想这就是FP中的情况吧？
defmodule Chatter.Room do
use GenServer
defmodule State do
defstruct size: 3, players: []
def is_full?(state) do
Enum.count(state.players) >= state
浏览 0提问于2016-01-03得票数 6
我有一个实现单个项目功能的GenServer，例如：
def handle_call({:sync, id}, _from, state) do
## update data
{:reply, data, sync}
end
现在，我想为多个I处理此功能，例如：
def handle_call({:sync_all, ids}, _from, state) do
## call sync for each id
data = Enum.map(ids, fn(id) ->
GenServer.call(self(), {:sync, id}
浏览 0提问于2016-10-24得票数 1
我正在实现一个GenServer，我很困惑。
我知道handle_cast是异步的，这意味着调用方没有等待回复，我们返回一个元组，如下所示：{:noreply, new_state}。
我注意到我们也可以从handle_call返回相同的元组。这是否意味着如果我有一个返回handle_call的{:noreply, new_state}，它将不会返回任何东西，但将是同步的？调用者的流将等待GenServer.call命令，然后在handle_call函数完成后继续吗？
浏览 0提问于2018-10-23得票数 1
回答已采纳
我缩小了问题的范围，因为它太大了。下面是代码：
defmodule MayRaiseGenServer do
use GenServer
def start_link do
IO.puts "started MyServer, name is #{__MODULE__}"
GenServer.start_link(__MODULE__, [], name: __MODULE__)
end
def maybe_will_raise do
GenServer.call(__MODULE__, :maybe_will_raise)
e
浏览 6提问于2016-09-01得票数 12
回答已采纳
2回答
当调用下面的监控程序代码时，我期望GenServer启动。GenServer没有启动，我想知道为什么以及如何修复它。
defmodule App.Service do
use GenServer
def start_link(state) do
GenServer.start_link(__MODULE__, state)
end
def init(state) do
{:ok, state}
end
def get_state(pid) do
GenServer.call(pid, :get_state)
end
def s
浏览 8提问于2022-10-23得票数 0
1回答
我在写论文申请书。我需要线性规划，但我的应用程序是用Elixir编写的，这实际上不是这种操作的语言。这就是为什么我决定使用Erlport作为Elixir依赖项，它能够将Python代码与Elixir连接起来。我还使用Pulp作为优化的python库。
灵丹妙药版本: 1.10.4，Erlport版本: 0.10.1，Python版本: 3.8.5，PuLP版本: 2.3
我为Elixir通信编写了这样一个模块，它利用GenServer作为Elixir和Python之间的主要“通信中心”：
defmodule MyApp.PythonHub do
use GenServer
def s
浏览 3提问于2020-10-12得票数 1
回答已采纳
1回答
我对灵丹妙药和OTP很陌生。
我想在我的服务器上使用GenServer.Behaviour，但是由于某些原因，长生不老药找不到它。我已经创建了一个混合项目，但是当我输入mix compile时，我会得到以下错误
文件lib/lecture3.ex ==编译错误：== ** (CompileError) lib/lecture3.ex:2:模块GenServer.Behaviour未加载，无法找到展开宏: Kernel.use/1 lib/lecture3.ex:2:缓存(模块)
我想我必须包括模块，但是怎么包括呢？
mix.exs:
defmodule LECTURE3.Mixfile
浏览 1提问于2016-11-26得票数 1
回答已采纳
1回答
我正在尝试解析一个由应用程序管理的GenServer，该应用程序注册了一个名为“灵丹妙药”的名称。下面是一些示例代码：
defmodule Experiment do
use Application
def start(_type, _args) do
child_specs = [
config_spec()
]
Supervisor.start_link(child_specs, name: Experiment, strategy: :one_for_one)
end
defp config_spec() do
%{
浏览 0提问于2019-05-10得票数 1
回答已采纳
2回答
了解GenServer的灵丹妙药
、、、、
我对“灵丹妙药”很陌生，我正在读一本书，并做一些例子。下面是一段代码，让我在这里提出问题：
defmodule Sequence.Server do
use GenServer
def init(initial_number)do
{:ok,initial_number}
end
def handle_call(:next_number, _from, current_number)do
{:reply, current_number,current_number+1}
end
end
如我所知，init函数
浏览 3提问于2018-07-06得票数 0
回答已采纳
在Phoenix框架上有一个应用程序。
需要GenServer，它将检查一些值。
这些值的验证是从控制器开始的(来自客户端的请求，检查GenServer值，客户端接收响应)。
一旦handle_call是同步的，那么当10个客户端一次调用10个handle_call时会发生什么？所有10个呼叫是并行处理还是按队列顺序处理？
浏览 4提问于2017-08-06得票数 2
回答已采纳
1回答
我是灵丹妙药的初学者，我正在努力理解如何使用GenServer。对我来说神奇的是：
defmodule Stack do
use GenServer
# Callbacks
def handle_call(:pop, _from, [h|t]) do
{:reply, h, t}
end
def handle_cast({:push, item}, state) do
{:noreply, [item|state]}
end
end
代码取自GenServer文档。为什么call函数在回调函数返回{:reply, h, t}时只返回一个值
#Sta
浏览 3提问于2016-05-02得票数 2
回答已采纳
在erlang中，如果没有尝试捕获，handle_call函数中的错误将使GenServer崩溃。当它崩溃时，很难找到问题在哪里，因为很多崩溃和重新启动日志。
我的问题是，为什么这么多handle_call没有try catch声明？有什么考虑吗？
以下代码来自项目stream.ex文件，仅供学习。
@impl true
def handle_call(:recv, from, {output, waiting, acc, fun}) do
case :queue.out(output) do
{:empty, output} ->
{:nor
浏览 6提问于2022-08-13得票数 0
回答已采纳
在书的第221页中，有人指出，如果我们想将call中的多个值传递给GenServer，我们应该使用元组：
def handle_call({:set_number, new_number}, _from, _current_number) do
{ :reply, new_number, new_number }
end
iex> GenServer.call(pid, {:set_number, 999})
在我看来，在这种情况下，关键字列表更适合：
def handle_call([ set_number: new_number ], _from, _current_number)
浏览 3提问于2015-12-17得票数 1
回答已采纳
我有这个GenServer/client实现，用于使用ETS的朴素缓存：
defmodule Cache do
use GenServer
def start_link() do
GenServer.start_link(__MODULE__, [])
end
def fetch(key, def_value) do
case get(key) do
{:not_found} -> set(key, def_value)
{:found, result} -> res
浏览 2提问于2017-10-17得票数 2
回答已采纳
嘿，所有人， 我对灵丹妙药还是个新手，对为灵丹妙药中的工人设置工人姓名和id感到迷惑，我希望有人能帮我一点忙。 我的应用程序文件 defmodule Squareup.Application do
# See https://hexdocs.pm/elixir/Application.html
# for more information on OTP Applications
@moduledoc false
use Application
def start(_type, _args) do
children = [
# Starts a wo
浏览 22提问于2020-08-15得票数 2
回答已采纳
我需要让GenServer监视一个任务，因此，我需要：
GenServer.call(server_pid, {:monitor_task, self()})
在服务器中：
def handle_call({:monitor_task, task_pid}, _from, state) do
ref = Process.monitor(task_pid)
{:reply, ref, state}
end
但是，我得到了错误：
** (stop) exited in: GenServer.call(#PID<0.768.0>, {:monitor_task, #PID<
浏览 1提问于2017-09-10得票数 2
回答已采纳
我得到了错误，模块GenServer.Behaviour没有加载，也找不到。
对于以下脚本：
defmodule FridgeServer do
use GenServer.Behaviour
def init(items) do
{:ok, items}
end
def handle_call({:store, item}, _from, items) do
{:reply, :ok, [item | items]}
end
end
我正在学习关于OTP的教程，并在运行OTP测试时收到了错误。我目前正在使用-v 1.4.2。
浏览 6提问于2017-04-29得票数 1
回答已采纳
是否有人在查询erlang时遇到此错误：
{：错误，:process_not_owner_of_odbc_connection}
我正在编写一个连接池，:ODBC.connect('conn )在genserver中运行，返回的pid被放入状态.但是当我将这个PID从gen服务器返回时，当我尝试使用这个pid运行一个:odbc.param_query时，我们应该如何创建一个连接池，如果我们可以使用在一个genserver中创建的pids呢？
有人有什么想法吗？
GenServer：
defmodule ItemonboardingApi.ConnectionPoolWorker
浏览 0提问于2018-03-05得票数 1
回答已采纳
在我的应用程序中有一个GenServer，它可以创建其他进程。所有进程ID都保存到一个列表中。 def create_process do
GenServer.call(__MODULE__, :create_process)
end
def handle_call(:create_process, _from, processes) do
{:ok, pid} = SomeProcess.start_link([])
{:reply, {:ok, pid}, [pid | processes]}
end 还有一个函数可以获取PID列表。 def get_proce
浏览 6提问于2019-01-26得票数 1
回答已采纳
我正试图在凤凰城的GenServer上工作，把从不同客户端接收到的信息积累到一个网络套接字上。GenServer看起来如下所示：
defmodule HelloWeb.Stack do
use GenServer
@name {:global, __MODULE__} # this seems to help me to prevent having to drag the pid everywhere in the application
# Client
def start_link do
#GenServer.start_link(__M
浏览 1提问于2018-02-20得票数 3
我有一个GenServer，它负责联系外部资源。调用外部资源的结果并不重要，每次失败都是可以接受的，因此使用handle_cast似乎适合于代码的其他部分。对于该外部资源，我确实有一个类似于接口的模块，并且我使用一个GenServer来访问该资源。到目前一切尚好。
但是当我试图为这个gen_server编写测试时，我想不出如何测试handle_cast。我有GenServer的接口函数，我试着测试这些接口函数，但是它们总是返回:ok，除非GenServer没有运行。我不能测试这个。
我把密码改了一点。我将handle_cast中的代码抽象为另一个函数，并创建了一个类似的handle_call回
浏览 1提问于2016-12-07得票数 4
回答已采纳
我一直在尝试弄清楚如何在调用进程B中捕获或挽救另一个进程A中的错误，该错误也杀死了进程A。
下面是我的代码：
defmodule A do
def start_link do
GenServer.start_link(__MODULE__, :ok, name: :A)
end
def fun(fun_loving_person) do
GenServer.call(fun_loving_person, :have_fun)
end
def init(:ok) do
{:ok, %{}}
end
def handle_call(:hav
浏览 0提问于2017-08-29得票数 2
我使用emacs开发erlang。gen_server文件是在创建骨架代码之后修改的。
下面是emacs的erlang骨架代码，它是由erlang的emacs插件创建的。
在尝试编写第一个灵丹妙药的gen_server时，我发现这个框架函数是vscode的elixir插件。
所以，我想知道是否有必要像以前一样做同样的例行工作？如果没有，为什么，如果是，怎么做？
-module(****).
-behaviour(gen_server).
%% API
-export([start_link/0]).
%% gen_server callbacks
-export([init/1, han
浏览 1提问于2022-06-25得票数 2
回答已采纳
我有一个使用2 GenServers的项目--第一个名为“GenServer”的GenServer维护状态，第二个GenServer使用“更新”维护状态的可能更新列表。我想要实现的是：
每次调用" state“时，"State”都应该在返回实际状态之前调用“更新”并更新自己。
这两个GenServers都是由主管启动的，我可以从外部调用两个GenServers的名称，但是如果我试图调用"State“中的”GenServers“的API，则"State”终止时会出现“无进程”错误。有什么建议吗？
def start_link(opts) do
Supe
浏览 0提问于2018-12-06得票数 1
回答已采纳
我正在尝试将消息队列从一个进程转移到另一个进程中。它是这样工作的:第一个进程(GenServer)启动，它按请求启动第二个进程。然后我在第一个进程中进行强制转换，这个强制转换调用第二个进程。在调用第二个进程I‘之前，尝试获取它的消息队列，但总是得到一个空队列。
defmodule First do
use GenServer
def start_link() do
GenServer.start_link(__MODULE__, %{}, name: __MODULE__)
end
def init(state) do
{:ok, Map.put(state, :proce
浏览 0提问于2018-03-23得票数 0
我只是在学习ETS和GenServer，当我的应用程序启动时，我正在尝试初始化一个缓存。很可能我设计的不正确，这导致了我在下面描述的问题，所以对此的任何反馈都是有帮助的。
当应用程序初始化时，:ets表是通过worker创建的。
def start_link do
GenServer.start_link(__MODULE__, :ok)
end
def init(:ok) do
tab = :ets.new(:my_table, [:set, :named_table])
:ets.insert(:my_table, {1, "one"})
{:ok, ta
浏览 0提问于2016-11-10得票数 1
回答已采纳
1回答
我有一个gen_server，它在每次调用计数器的increment()函数时递增计数器。
-module(genserver).
-export([start_link/0, start/0, increment/0]).
-behaviour(gen_server).
-export([init/1, handle_call/3, handle_cast/2, handle_info/2, terminate/2, code_change/3]).
init([]) ->
{ok, "counter.txt"}.
start() ->
gen
浏览 2提问于2016-07-14得票数 2
回答已采纳
1回答
我有一个带有产品模式的菲尼克斯测试应用程序。我有一个由主应用程序主管启动的GenServer，它使用handle_call获取产品列表。
def handle_call(:get_products, _from, _state)
products = Repo.all(Product)
{:reply, products, products}
end
现在我想为这个GenServer编写一个测试。
我试着在考试中做这样的事
setup do
pid = Process.whereis(MyGenServer)
Ecto.Adapters.SQL.Sandbox.allow(Re
浏览 1提问于2017-07-16得票数 0
回答已采纳
我故意在GenServer中调用不存在的函数，以查看监控程序在崩溃后是否会重新启动它，如下所示：
GenServer.call(:global.whereis_name("MyServer"), {:doesnotexist, ""})
它不仅会导致进程崩溃，而且整个应用程序也会被关闭。终止函数将触发并显示handle_call不处理不存在的:不存在，因为它不存在。
是的，我创建了主管并使用了start_child，在子GenServer中，我使用了GenServer.start_link/3，所以所有这些都应该工作。
如果我使用Process.exit(:gl
浏览 3提问于2022-10-07得票数 0
回答已采纳
1回答
我正试图完成一项简单的任务，但我遇到了巨大的困难。
假设我有一个GenServer，其中一个回调如下：
@impl true
def handle_call(:state, _, state) do
# Something that would require 10 seconds
newState = do_job()
{:reply, newState, newState}
end
如果我是对的，从客户端调用GenServer.call(:server, :state)将阻塞服务器10秒，然后将新状态返回给客户机。
好的。我希望服务器在不被阻止的情况下处
浏览 2提问于2018-12-15得票数 2
回答已采纳
我不知道我做错了什么，但我已经创建了一个灵丹妙药应用程序，如果我运行它时：
iex -S mix
应用程序加载监控器，监控器加载连接到rabbitmq并一直侦听消息的gen_server，但是如果我使用
mix app.start
或
mix run
监控器被加载，工作人员被启动并连接到rabbitmq，但是它立即结束，没有任何错误，示例代码：
mix.exs
defmodule Sample.Mixfile do
use Mix.Project
def project do
[app: :sample,
version: "0.0.1",
浏览 2提问于2015-07-03得票数 4
回答已采纳
我正在尝试启动一个主管程序和一个GenServer：
defmodule SubscriptionManagerSupervisor do
use Supervisor
def start_link do
Supervisor.start_link(__MODULE__, [], [{:name, __MODULE__}])
end
# supervisor callback
def init([]) do
interval = 1000
children = worker(SubscriptionManagerServer, [interval
浏览 3提问于2016-09-07得票数 0
回答已采纳
我在与在我的dynamicSupervisor中创建的工人的沟通中遇到了问题。启动所有员工后，我尝试通过pid调用一个，并生成一个错误(总是)。在孩子开始的时候，我用ets保持pid。然后，当我想调用这个子函数时，我通过一个标识符从ets获得pid。到目前一切尚好。问题是，当我做以下工作时：
GenServer.call(
pid,
{:action_project, %{project_id: project_id, pid: :erlang.pid_to_list(pid)}}
)
返回以下错误：
[error] GenServer #PID<0.606.0> term
浏览 0提问于2018-11-23得票数 1
回答已采纳
1回答
我是灵丹妙药的初学者，我正在开发一个简单的多通道聊天服务器。
我的通道是一个GenServer，它存储一个用户列表(pids)，以及一个处理用户进程崩溃的映射(用户参考-> pid) (来自)。但是，由于它是一个以引用作为键的映射，当我实现remove_member_from_channel函数时，我想要删除pid (映射的值)，我怎么做呢？还是我选择了错误的方式来实现它？
defmodule Chat.Channel do
use GenServer
# ......
def add_member(channel, user) do
GenServer.call
浏览 0提问于2018-04-11得票数 0
回答已采纳
1回答
背景
我有一个伞式应用程序，里面有很多较小的应用。其中一个名为A的应用程序需要能够旋转并监督另一个名为B的应用程序。
B本身就是一个应用程序，它公开一个公共API并拥有一个GenServer，负责接收请求，然后重定向到逻辑模块等等。
问题
因此，我有两个要求：
app.A i必须能够独立地启动B，并使其作为一个正常的独立的B工作，如果需要的话，它必须能够在其子代中拥有B并重新启动/管理它。
我在这里遇到的问题是，使用我的代码，我可以实现1或2，但不能两者兼得。
代码
因此，下面是app B的重要代码
application.ex
defmodule B.Application do
@mo
浏览 4提问于2021-01-04得票数 0
回答已采纳
1回答
我对一些OTP概念还不熟悉。我有GenServer，它会将事件发布到RabbitMQ。这个GenServer的状态是：amqp Chanel，它在init()期间启动一次，并且在cast调用之间持久。 defmodule Myapp.Events.AmqpTransport do
require Logger
use GenServer
use AMQP
def start_link(_) do
GenServer.start_link(__MODULE__, [], name: __MODULE__)
end
def init(_opts) do
浏览 32提问于2020-11-02得票数 3
回答已采纳
在我的GenServer中，我有一个原子阵列来表示状态。我不想把队列中的最后一项弹出，我想立刻跳掉所有的状态。
现行守则(不起作用)
defmodule ScoreTableQueue do
use GenServer
@impl true
def init(stack) do
{:ok, stack}
end
@impl true
def handle_call(:pop, _from, [state]) do
{:reply, [state]}
end
@impl true
def handle_cast({:push, item}
浏览 2提问于2018-10-14得票数 1
回答已采纳
我有一个简单的GenServer，如下所示：
GenServer：
defmodule MyApp.ScoreTableQueue do
use GenServer
@impl true
def init(stack) do
{:ok, stack}
end
@impl true
def handle_call(:pop, _from, state) do
{:reply, state, []}
end
@impl true
def handle_cast({:push, item}, state) do
{:noreply,
浏览 0提问于2018-10-14得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
