Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 142 for rocks (0.02 sec)

  1. docs/ja/docs/tutorial/body-nested-models.md

    {!../../docs_src/body_nested_models/tutorial004.py!}
    ```
    
    これは **FastAPI** が以下のようなボディを期待することを意味します:
    
    ```JSON
    {
        "name": "Foo",
        "description": "The pretender",
        "price": 42.0,
        "tax": 3.2,
        "tags": ["rock", "metal", "bar"],
        "image": {
            "url": "http://example.com/baz.jpg",
            "name": "The Foo live"
        }
    }
    ```
    
    繰り返しになりますが、**FastAPI** を使用して、その宣言を行うだけで以下のような恩恵を受けられます:
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

    import java.util.concurrent.Future;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  3. cmd/metacache-manager.go

    	"github.com/minio/minio/internal/logger"
    )
    
    // localMetacacheMgr is the *local* manager for this peer.
    // It should never be used directly since buckets are
    // distributed deterministically.
    // Therefore no cluster locks are required.
    var localMetacacheMgr = &metacacheManager{
    	buckets: make(map[string]*bucketMetacache),
    	trash:   make(map[string]metacache),
    }
    
    type metacacheManager struct {
    	mu      sync.RWMutex
    	init    sync.Once
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

    import java.util.concurrent.Future;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Utilities for treating interruptible operations as uninterruptible. In all cases, if a thread is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

    import java.util.concurrent.TimeUnit
    import java.util.concurrent.locks.Condition
    import java.util.concurrent.locks.ReentrantLock
    import okhttp3.internal.EMPTY_BYTE_ARRAY
    import okhttp3.internal.EMPTY_HEADERS
    import okhttp3.internal.assertThreadDoesntHoldLock
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.http2.ErrorCode.REFUSED_STREAM
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  6. cmd/metacache.go

    }
    
    // keepAlive will continuously update lastHandout until ctx is canceled.
    func (m metacache) keepAlive(ctx context.Context, rpc *peerRESTClient) {
    	// we intentionally operate on a copy of m, so we can update without locks.
    	t := time.NewTicker(metacacheMaxClientWait / 10)
    	defer t.Stop()
    	for {
    		select {
    		case <-ctx.Done():
    			// Request is done, stop updating.
    			return
    		case <-t.C:
    			m.lastHandout = time.Now()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/Queues.java

        int added = 0;
        while (added < numElements) {
          // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
          // elements already available (e.g. LinkedBlockingQueue#drainTo locks only once)
          added += q.drainTo(buffer, numElements - added);
          if (added < numElements) { // not enough elements immediately available; will have to poll
            E e = q.poll(deadline - System.nanoTime(), NANOSECONDS);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 26 14:11:14 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt

     * limitations under the License.
     */
    package okhttp3.internal.concurrent
    
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.RejectedExecutionException
    import java.util.concurrent.locks.ReentrantLock
    import kotlin.concurrent.withLock
    import okhttp3.internal.assertNotHeld
    import okhttp3.internal.okHttpName
    
    /**
     * A set of tasks that are executed in sequential order.
     *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  9. cmd/namespace-lock.go

    func (di *distLockInstance) RUnlock(lc LockContext) {
    	if lc.cancel != nil {
    		lc.cancel()
    	}
    	di.rwMutex.RUnlock(lc.ctx)
    }
    
    // localLockInstance - frontend/top-level interface for namespace locks.
    type localLockInstance struct {
    	ns     *nsLockMap
    	volume string
    	paths  []string
    	opsID  string
    }
    
    // NewNSLock - returns a lock instance for a given volume and
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/collect/ConcurrentHashMultisetTest.java

        assertEquals(0, cms.count("a"));
        assertTrue(cms.removeExactly("b", 2));
        assertEquals(1, cms.count("b"));
      }
    
      public void testIteratorRemove_actualMap() {
        // Override to avoid using mocks.
        multiset = ConcurrentHashMultiset.create();
    
        multiset.add(KEY);
        multiset.add(KEY + "_2");
        multiset.add(KEY);
    
        int mutations = 0;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 14.2K bytes
    - Viewed (0)
Back to top