Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 91 for recv_a (0.12 sec)

  1. test/escape_reflect.go

    	mv := reflect.ValueOf(m)
    	it.Reset(mv)
    }
    
    func recv1(ch chan string) string { // ERROR "ch does not escape"
    	v := reflect.ValueOf(ch)
    	r, _ := v.Recv()
    	return r.String()
    }
    
    func recv2(ch chan string) string { // ERROR "ch does not escape"
    	v := reflect.ValueOf(ch)
    	r, _ := v.TryRecv()
    	return r.String()
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 08 18:50:24 UTC 2023
    - 13.1K bytes
    - Viewed (0)
  2. docs/pt/docs/tutorial/background-tasks.md

    - Processando dados:
      - Por exemplo, digamos que você receba um arquivo que deve passar por um processo lento, você pode retornar uma resposta de "Aceito" (HTTP 202) e processá-lo em segundo plano.
    
    ## Usando `BackgroundTasks`
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Mon May 09 23:44:32 UTC 2022
    - 5.3K bytes
    - Viewed (0)
  3. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/unmarshal/unmarshal.go

    		argidx := -1
    
    		recv := fn.Type().(*types.Signature).Recv()
    		if fn.Name() == "Unmarshal" && recv == nil {
    			// "encoding/json".Unmarshal
    			// "encoding/xml".Unmarshal
    			// "encoding/asn1".Unmarshal
    			switch fn.Pkg().Path() {
    			case "encoding/json", "encoding/xml", "encoding/asn1":
    				argidx = 1 // func([]byte, interface{})
    			}
    		} else if fn.Name() == "Decode" && recv != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  4. src/internal/types/testdata/examples/functions.go

    func fsend[T any](chan<- T) {}
    
    func _() {
    	var both chan int
    	var recv <-chan int
    	var send chan<-int
    
    	fboth(both)
    	fboth(recv /* ERROR "cannot use" */ )
    	fboth(send /* ERROR "cannot use" */ )
    
    	frecv(both)
    	frecv(recv)
    	frecv(send /* ERROR "cannot use" */ )
    
    	fsend(both)
    	fsend(recv /* ERROR "cannot use" */)
    	fsend(send)
    }
    
    func ffboth[T any](func(chan T)) {}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 30 20:19:38 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  5. tensorflow/compiler/mlir/tensorflow/ir/tf_device_ops.td

        communication via send/recvs). In this case, users of ParallelExecute op
        must provide correct control dependencies between regions to guarantee
        correctness. Regions in ParallelExecute may include Resource ops.
    
        In the case where different regions include ops access the same resource,
        the users of the ParallelExecute op must provide mechanism (via send/recvs
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jan 23 23:53:20 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  6. test/fixedbugs/bug225.go

    // license that can be found in the LICENSE file.
    
    package main
    
    func main() {	
    	c := make(chan bool, 1);
    	select {
    	case _ = <-c:
    		panic("BUG: recv should not");
    	default:
    	}
    	c <- true;
    	select {
    	case _ = <-c:
    	default:
    		panic("BUG: recv should");
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Feb 17 04:49:30 UTC 2012
    - 375 bytes
    - Viewed (0)
  7. tensorflow/c/eager/c_api_test_util.h

                   const std::string& recv_device,
                   tensorflow::uint64 send_device_incarnation);
    
    // Return a RecvOp op `op_name` with the attributes `send_device`,
    // `recv_device`, and `send_device_incarnation` set.
    TFE_Op* RecvOp(TFE_Context* ctx, const std::string& op_name,
                   const std::string& send_device, const std::string& recv_device,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon Jul 17 23:43:59 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  8. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/timeformat/timeformat.go

    func isTimeDotFormat(f *types.Func) bool {
    	if f.Name() != "Format" || f.Pkg() == nil || f.Pkg().Path() != "time" {
    		return false
    	}
    	// Verify that the receiver is time.Time.
    	recv := f.Type().(*types.Signature).Recv()
    	return recv != nil && analysisutil.IsNamedType(recv.Type(), "time", "Time")
    }
    
    func isTimeDotParse(f *types.Func) bool {
    	return analysisutil.IsFunctionNamed(f, "time", "Parse")
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  9. tensorflow/compiler/mlir/tf2xla/transforms/legalize_tf_communication.cc

      auto recv =
          builder.create<RecvOp>(loc, recv_result_type, token, channel_handle,
                                 /*is_host_transfer=*/builder.getBoolAttr(true));
    
      SetFrontendAttributes(recv, index, key, result_type,
                            /*device_to_host=*/false, host_handler_name);
    
      SetOpSharding(recv, manual_sharding);
    
      result.replaceAllUsesWith(recv.getResult(0));
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 40.5K bytes
    - Viewed (0)
  10. src/go/internal/srcimporter/srcimporter_test.go

    	for i := 0; i < iface.NumExplicitMethods(); i++ {
    		m := iface.ExplicitMethod(i)
    		recv := m.Type().(*types.Signature).Recv()
    		if recv == nil {
    			t.Errorf("%s: missing receiver type", m)
    			continue
    		}
    		if recv.Type() != named {
    			t.Errorf("%s: got recv type %s; want %s", m, recv.Type(), named)
    		}
    	}
    
    	// check embedded interfaces (they are named, too)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 12 12:00:02 UTC 2023
    - 6.5K bytes
    - Viewed (0)
Back to top