org.zeromq.ZContext.destroy()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-15 00:08:49 27 4

synchronized public void shutdown()
{
  if (!destoryed) {
    context.destroy();
    destoryed = true;
  }
}

@Override
public void close()
{
  destroy();
}

public void shutdown()
  {
    LOG.info("Reader front shutting down");

    ZLogManager.instance().shutdown();

    context.destroy();
    LOG.info("Reader front ended");
  }
}

public void shutdown() {
  LOG.info("Writer front shutting down");
  ZLogManager.instance().shutdown();
  context.destroy();
  LOG.info("Writer front ended");
}

public void shutdown() {
  if (closed) {
    return;
  }
  zloop.removePoller(pollin);
  zloop.destroy();
  closed = true;
  if (shutdownCtx) {
    zmq.destroy();
  }
}

context.destroy();

public void shutdown() {
  if (closed) {
    return;
  }
  zloop.removePoller(pollin);
  zloop.destroy();
  closed = true;
  if (shutdownCtx) {
    zmq.destroy();
  }
  b.onComplete();
}

@Override
public void run()
{
  LOG.info("Started Worker " + identity);
  worker = context.createSocket(ZMQ.DEALER);
  worker.setIdentity(identity.getBytes());
  worker.connect(bindAddr);
  try {
    loop();
  } catch (ZMQException e) {
    if (e.getErrorCode() != ZMQ.Error.ETERM.getCode())
      throw e;
  }
  context.destroy();
  LOG.info("Ended Reader Worker " + identity);
}

@Override
public void run()
{
  LOG.info("Started Worker " + identity);
  worker = context.createSocket(ZMQ.DEALER);
  worker.setRcvHWM(2000);
  worker.setIdentity(identity.getBytes());
  worker.connect(bindAddr);
  try {
    loop();
  } catch (ZMQException e) {
    if (e.getErrorCode() != ZMQ.Error.ETERM.getCode())
      throw e;
  }
  LOG.info("Ended Writer Worker " + identity);
  context.destroy();
}

@Override
  public void run()
  {
    if (attachedRunnable != null) {
      try {
        attachedRunnable.run(args, ctx, pipe);
      }
      catch (ZMQException e) {
        if (e.getErrorCode() != Error.ETERM.getCode()) {
          throw e;
        }
      }
      ctx.destroy();
    }
    else {
      detachedRunnable.run(args);
    }
  }
}

27 4 0

• ruby-on-rails - rails : how to disable before_destroy callback when it's being destroyed because of the parent is being destroyed (:dependent => :destroy)

  我有两个类(class): parent 和 child child : belongs_to :parent 和 家长 has_many :children, :dependent => :dest

• ruby-on-rails - Has_many 通过关联依赖 : destroy not destroying

  我有这个模型 class XmlImport ["text/xml"] end :event_import_records 条目正在被销毁。但是 :events 不是。 has_many throu

• terraform - 亚特实验室 CI : terraform destroy doesn't destroy?

  我定义了以下简单的管道: image: name: hashicorp/terraform:light entrypoint: - '/usr/bin/env' - 'PATH

• terraform - 亚特实验室 CI : terraform destroy doesn't destroy?

  我定义了以下简单的管道: image: name: hashicorp/terraform:light entrypoint: - '/usr/bin/env' - 'PATH

• ruby-on-rails - 触发依赖 : :destroy with overridden destroy-method

  在我们的应用程序中，我们覆盖了 ActiveRecord destroy 方法，以便我们的记录不会被删除(因此用户可以取消删除)。像这样: def destroy self.is_deleted

• ruby-on-rails - :dependent => :destroy isn't calling the destroy method before the deletion?

  我有一个笔记模型，具有以下关联 注意.rb has_many :note_categories, :dependent => :destroy has_many :categories, :throu

• python - Tcl 错误 : can't invoke "destroy" command: application has been destroyed

  我是一名 Python 初学者。尝试制作一个新按钮来关闭窗口。我收到错误消息: Exception in Tkinter callback Traceback (most recent call la

• ruby-on-rails - CommentsController :Class in my destroy comment method 的未定义局部变量或方法 `destroy'

  我在我的应用程序中添加了评论功能，到目前为止一切正常，直到出现此错误。我所做的是添加了删除评论功能。当我启动服务器时一切正常，但在我单击“删除”按钮后问题出现了。 错误信息 undefined loc

• ruby-on-rails - Rails，def destroy，没有响应 destroy.js.erb，为什么？

  Rails，def destroy，没有响应 destroy.js.erb 这是我的方法: # DELETE /Groups/1 # DELETE /Groups/1.xml def de

• oop - Excel VBA : Does destroying a collection of objects destroy every single object?

  假设我有一个 MyClass 对象的集合 MyCollection。 Set MyCollection = Nothing 是否调用每个包含的对象的析构函数，或者我应该单独设置每个对象 = Nothi

• javascript - 蒙哥错误: topology was destroyed(when finding the documents) and instance pool was destroyed (when inserting documents)

  我正在尝试使用 Node.js、Express 和 Mongodb 构建 REST API。我正在使用 mongodb npm 包连接到数据库，下面是我的 sever.js 文件代码 var expr

• ruby-on-rails - ruby rails 3 : after destroy method to destroy object if there is no more related objects in the system?

  我有一个小问题，我有以下两个模型: class CriticalProcess :destroy has_many :roles, :through => :authorizations a

• Angular 2 错误 : Attempt to use a destroyed view: detectChanges Error: Attempt to use a destroyed view: detectChanges at ViewDestroyedError

  我正在使用 ng2-toastr 并收到以下错误 https://www.npmjs.com/package/ng2-toastr Attempt to use a destroyed view: d

• networking - 级别=致命的消息=“ipset [destroy] failed: ipset v6.29: Set cannot be destroyed: it is in use by a kernel component\n: exit status 1”

  基本信息: 系统: # cat /proc/version Linux version 3.10.0-514.2.2.el7.x86_64 (builder@kbuilder.dev.centos.o

• ThreadGroup 的 destroy

  一 点睛 destroy 用于销毁 ThreadGroup，该方法只是针对一个没有任何 active 线程的 group 进行一次 destroy 标记，调用该方法的直接结果是在父 group 中将自

• perl - DESTROY 以意外的顺序调用

  我开始注意到 Scope::Guard 的一些奇怪之处。 . 如果我取消定义 $guard变量作为 sub 中的最后一个语句，守卫的 sub 得到 比我预期的要晚打电话。 如果我不取消它，或者如果我做

• AngularJS $destroy 动态插入的组件

  我正在构建一个提供打开和关闭它的服务的模式。该模式有一个控制关闭按钮的小 Controller ，以及进入模式内容的模板的 $compile。 那个模板就是一个组件，当然，那个组件有一个 Contro

• AngularJS:指令范围没有被调用 $destroy

  一直在文件馆和网上寻找答案，但没有真正找到答案，只是零零碎碎。似乎有很多建议的帖子，但没有一个有答案。 我有一个使用范围的复杂指令:true。它实际上是我正在尝试为其编写清理代码的 ng-grid 最

• delphi - 为什么不调用 Destroy？

  给定以下 Delphi 代码，Foo 在 FormClose 上是 Free，但 TFoo.Destroy 是没有被调用 - 因此 Bar 没有被 Free'd，导致内存泄漏？ 我是否在这里错过了一些

• AngularJS - $destroy 是否删除事件监听器？

  https://docs.angularjs.org/guide/directive By listening to this event, you can remove event listener