Monitor - Code Search

guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      @Override
      protected void runTest() throws Throwable {
        Monitor monitor1 = new Monitor(fair1);
        Monitor monitor2 = new Monitor(fair2);
        FlagGuard guard = new FlagGuard(monitor2);
        List<Object> arguments = new ArrayList<>();
        arguments.add(guard);
        if (isDurationBased(method)) {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Tue Jul 23 14:18:12 UTC 2024

- 27.1K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      @Override
      protected void runTest() throws Throwable {
        Monitor monitor1 = new Monitor(fair1);
        Monitor monitor2 = new Monitor(fair2);
        FlagGuard guard = new FlagGuard(monitor2);
        List<Object> arguments = new ArrayList<>();
        arguments.add(guard);
        if (isDurationBased(method)) {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Oct 19 00:51:36 UTC 2024

- 27.1K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/AbstractService.java

        return "stopping({from = " + from + "})";
      }
    };
  }

  private final Monitor monitor = new Monitor();

  private final Guard isStartable = new IsStartableGuard();

  @WeakOuter
  private final class IsStartableGuard extends Guard {
    IsStartableGuard() {
      super(AbstractService.this.monitor);
    }

    @Override
    public boolean isSatisfied() {
      return state() == NEW;

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri May 12 18:32:03 UTC 2023

- 20.4K bytes

- Viewed (0)

github.com/google/guava

guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java

    if (e == null) throw new NullPointerException();
    final Monitor monitor = this.monitor;
    monitor.enterWhen(notFull);
    try {
      insert(e);
    } finally {
      monitor.leave();
    }
  }

  @CanIgnoreReturnValue
  @Override
  public @Nullable E poll() {
    final Monitor monitor = this.monitor;
    if (monitor.enterIf(notEmpty)) {
      try {
        return extract();

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Wed Apr 19 19:24:36 UTC 2023

- 22.5K bytes

- Viewed (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

  @Override
  public <T> T[] toArray(T[] a) {
    final Monitor monitor = this.monitor;
    monitor.enter();
    try {
      return q.toArray(a);
    } finally {
      monitor.leave();
    }
  }

  @CanIgnoreReturnValue // pushed down from class to method
  @Override
  public String toString() {
    final Monitor monitor = this.monitor;
    monitor.enter();
    try {
      return q.toString();

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Jun 07 21:36:32 UTC 2024

- 19K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/AbstractService.java

        return "stopping({from = " + from + "})";
      }
    };
  }

  private final Monitor monitor = new Monitor();

  private final Guard isStartable = new IsStartableGuard();

  @WeakOuter
  private final class IsStartableGuard extends Guard {
    IsStartableGuard() {
      super(AbstractService.this.monitor);
    }

    @Override
    public boolean isSatisfied() {
      return state() == NEW;

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri May 12 18:32:03 UTC 2023

- 20.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/ServiceManager.java

  private static final class ServiceManagerState {
    final Monitor monitor = new Monitor();

    @GuardedBy("monitor")
    final SetMultimap<State, Service> servicesByState =
        MultimapBuilder.enumKeys(State.class).linkedHashSetValues().build();

    @GuardedBy("monitor")
    final Multiset<State> states = servicesByState.keys();

    @GuardedBy("monitor")

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Oct 19 00:51:36 UTC 2024

- 33.5K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/util/concurrent/ServiceManager.java

  private static final class ServiceManagerState {
    final Monitor monitor = new Monitor();

    @GuardedBy("monitor")
    final SetMultimap<State, Service> servicesByState =
        MultimapBuilder.enumKeys(State.class).linkedHashSetValues().build();

    @GuardedBy("monitor")
    final Multiset<State> states = servicesByState.keys();

    @GuardedBy("monitor")

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Sat Oct 19 00:51:36 UTC 2024

- 33.2K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java

import org.opensearch.monitor.jvm.JvmStats;
import org.opensearch.monitor.jvm.JvmStats.BufferPool;
import org.opensearch.monitor.jvm.JvmStats.Classes;
import org.opensearch.monitor.jvm.JvmStats.GarbageCollectors;
import org.opensearch.monitor.jvm.JvmStats.Mem;
import org.opensearch.monitor.jvm.JvmStats.Threads;
import org.opensearch.monitor.os.OsProbe;
import org.opensearch.monitor.os.OsStats;

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 12.1K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/exec/SuggestCreator.java

import org.lastaflute.di.core.external.GenericExternalContextComponentDefRegister;
import org.lastaflute.di.core.factory.SingletonLaContainerFactory;
import org.opensearch.monitor.jvm.JvmInfo;
import org.opensearch.monitor.os.OsProbe;
import org.opensearch.monitor.process.ProcessProbe;

import jakarta.annotation.Resource;

public class SuggestCreator {

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Thu Feb 22 01:53:18 UTC 2024

- 10K bytes

- Viewed (0)

Search Options