本文整理了Java中io.vertx.core.Context.owner()方法的一些代码示例，展示了Context.owner()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Context.owner()方法的具体详情如下：
包路径：io.vertx.core.Context
类名称：Context
方法名：owner

Context.owner介绍

暂无

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public Vertx vertx() {
 return ctx.owner();
}

代码示例来源：origin: eclipse-vertx/vert.x

LockWaiter(Context context, String lockName, long timeout, Handler<AsyncResult<Lock>> handler) {
 this.context = context;
 this.lockName = lockName;
 this.handler = handler;
 status = new AtomicReference<>(Status.WAITING);
 timerId = timeout != Long.MAX_VALUE ? context.owner().setTimer(timeout, tid -> timeout()) : null;
}

代码示例来源：origin: eclipse-vertx/vert.x

void acquireLock() {
  if (status.compareAndSet(Status.WAITING, Status.ACQUIRED)) {
   if (timerId != null) {
    context.owner().cancelTimer(timerId);
   }
   context.runOnContext(v -> handler.handle(Future.succeededFuture(new AsyncLock(lockName))));
  } else {
   context.runOnContext(v -> nextWaiter(lockName));
  }
 }
}

代码示例来源：origin: eclipse-vertx/vert.x

public synchronized <T> void executeBlocking(Handler<Future<T>> blockingCodeHandler, boolean ordered, Handler<AsyncResult<T>> asyncResultHandler) {
 if (closed) {
  throw new IllegalStateException("Worker executor closed");
 }
 ContextImpl context = (ContextImpl) ctx.owner().getOrCreateContext();
 context.executeBlocking(blockingCodeHandler, asyncResultHandler, pool.executor(), ordered ? context.orderedTasks : null, pool.metrics());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public HttpServerFileUpload streamToFileSystem(String filename) {
 pause();
 context.owner().fileSystem().open(filename, new OpenOptions(), ar -> {
  if (ar.succeeded()) {
   file =  ar.result();
   Pump p = Pump.pump(HttpServerFileUploadImpl.this, ar.result());
   p.start();
   resume();
  } else {
   notifyExceptionHandler(ar.cause());
  }
 });
 return this;
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 Future<Void> handle(ReadStream<Buffer> stream) {
  Future<Void> fut = Future.future();
  assert fetching.getAndSet(false);
  Vertx.currentContext().owner().setTimer(1, id -> {
   assert !fetching.getAndSet(true);
   stream.fetch(1);
   fut.complete();
  });
  return fut;
 }
};

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 Future<Void> handle(ReadStream<Buffer> stream) {
  Future<Void> fut = Future.future();
  assert flowing.getAndSet(false);
  stream.pause();
  Vertx.currentContext().owner().setTimer(1, id -> {
   assert !flowing.getAndSet(true);
   stream.resume();
   fut.complete();
  });
  return fut;
 }
},

代码示例来源：origin: io.vertx/vertx-core

@Override
public Vertx vertx() {
 return ctx.owner();
}

代码示例来源：origin: apache/servicecomb-java-chassis

protected void startCheckTimeout(Context context) {
 context.owner().setPeriodic(TimeUnit.SECONDS.toMillis(1), this::onCheckTimeout);
}

代码示例来源：origin: resteasy/Resteasy

@Override
public boolean setTimeout(long time, TimeUnit unit)
{
 synchronized (responseLock)
 {
   if (done || cancelled) return false;
   if (timerID > -1 && !context.owner().cancelTimer(timerID))
   {
    return false;
   }
   timerID = context.owner().setTimer(unit.toMillis(time), v -> handleTimeout());
 }
 return true;
}

代码示例来源：origin: io.vertx/vertx-core

LockWaiter(Context context, String lockName, long timeout, Handler<AsyncResult<Lock>> handler) {
 this.context = context;
 this.lockName = lockName;
 this.handler = handler;
 status = new AtomicReference<>(Status.WAITING);
 timerId = timeout != Long.MAX_VALUE ? context.owner().setTimer(timeout, tid -> timeout()) : null;
}

代码示例来源：origin: apache/servicecomb-java-chassis

@Override
 public void execute(Runnable command) {
  Vertx.currentContext().owner().executeBlocking(future -> {
     command.run();
    },
    false,
    null);
 }
}

代码示例来源：origin: apache/servicecomb-java-chassis

@Override
public CLIENT_POOL createClientPool(Context context) {
 Vertx vertx = context.owner();
 NetClientWrapper netClientWrapper = new NetClientWrapper(vertx, normalClientConfig, sslClientConfig);
 return doCreateClientPool(context, netClientWrapper);
}

代码示例来源：origin: apache/servicecomb-java-chassis

@Override
 public HttpClientWithContext createClientPool(Context context) {
  HttpClient httpClient = context.owner().createHttpClient(httpClientOptions);

  return new HttpClientWithContext(httpClient, context);
 }
}

代码示例来源：origin: io.vertx/vertx-core

void acquireLock() {
  if (status.compareAndSet(Status.WAITING, Status.ACQUIRED)) {
   if (timerId != null) {
    context.owner().cancelTimer(timerId);
   }
   context.runOnContext(v -> handler.handle(Future.succeededFuture(new AsyncLock(lockName))));
  } else {
   context.runOnContext(v -> nextWaiter(lockName));
  }
 }
}

代码示例来源：origin: io.vertx/vertx-core

public synchronized <T> void executeBlocking(Handler<Future<T>> blockingCodeHandler, boolean ordered, Handler<AsyncResult<T>> asyncResultHandler) {
 if (closed) {
  throw new IllegalStateException("Worker executor closed");
 }
 ContextImpl context = (ContextImpl) ctx.owner().getOrCreateContext();
 context.executeBlocking(blockingCodeHandler, asyncResultHandler, pool.executor(), ordered ? context.orderedTasks : null, pool.metrics());
}

代码示例来源：origin: apache/servicecomb-java-chassis

/**
 *
 * @param file
 * @param openOptions
 * @return future of save to file, future complete means write to file finished
 */
public CompletableFuture<File> saveToFile(File file, OpenOptions openOptions) {
 CompletableFuture<File> future = new CompletableFuture<>();
 context.runOnContext((v) -> {
  Vertx vertx = context.owner();
  vertx.fileSystem().open(file.getAbsolutePath(), openOptions, ar -> {
   onFileOpened(file, ar, future);
  });
 });
 return future;
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public HttpServerFileUpload streamToFileSystem(String filename) {
 pause();
 context.owner().fileSystem().open(filename, new OpenOptions(), ar -> {
  if (ar.succeeded()) {
   file =  ar.result();
   Pump p = Pump.pump(HttpServerFileUploadImpl.this, ar.result());
   p.start();
   resume();
  } else {
   notifyExceptionHandler(ar.cause());
  }
 });
 return this;
}

代码示例来源：origin: io.vertx/vertx-core

@Override
 Future<Void> handle(ReadStream<Buffer> stream) {
  Future<Void> fut = Future.future();
  assert fetching.getAndSet(false);
  Vertx.currentContext().owner().setTimer(1, id -> {
   assert !fetching.getAndSet(true);
   stream.fetch(1);
   fut.complete();
  });
  return fut;
 }
};

代码示例来源：origin: io.vertx/vertx-core

@Override
 Future<Void> handle(ReadStream<Buffer> stream) {
  Future<Void> fut = Future.future();
  assert flowing.getAndSet(false);
  stream.pause();
  Vertx.currentContext().owner().setTimer(1, id -> {
   assert !flowing.getAndSet(true);
   stream.resume();
   fut.complete();
  });
  return fut;
 }
},