Method Compute

tensorflow/core/kernels/work_queue_ops.cc:207–213

  }

  void Compute(OpKernelContext* ctx) override {
    WorkQueue* work_queue = new WorkQueue(shared_name_);
    Status s = CreateResource(ctx, HandleFromInput(ctx, 0), work_queue);
    if (!s.ok() && s.code() != error::ALREADY_EXISTS) {
      OP_REQUIRES(ctx, false, s);
    }
  }

 private:
  string shared_name_;