标签: synchronization

我想使用Vagrant为我的团队提供一个共同的开发环境.主机完全不同:

• 有些使用OS X,有些Linux和一些Windows.
• 有些使用VMware,有些使用VirtualBox.

在VM内部我们想要运行Linux.

到目前为止,一切都很好.

现在我们的想法是每个开发人员都应该能够使用他们选择的IDE,因此我们引入了一个同步文件夹,该文件夹共享主机和VM之间的源代码.这基本上也适用......除了符号链接.

在我们的源代码中,我们实际上有一些符号链接,这在VM内部的Linux中不是问题,但在Windows上作为主机,这会导致问题.我们唯一不能做的就是摆脱符号链接,所以我们需要另一种方法来解决这个问题.

到目前为止,我们尝试了许多选择:

• 在Vagrant 问题中提到了一种解决方法,不幸的是,这只是VirtualBox,并没有帮助那些运行VMware的人.到目前为止,我们还没有找到在Vagrantfile中运行代码的方法,具体取决于使用的提供程序.
• 我们现在尝试使用rsync类型,而不是使用标准的共享文件夹.这适用于Windows,但在OS X上崩溃时会出现一些错误,告诉我们symlink has no referent(每个符号链接有一个错误).
• 我们考虑过NFS,但只有在不使用Windows作为主机时才有效.
• 我们也关于SMB,但这只能在Windows上作为主机使用.

我无法想象我们是这个星球上唯一或第一个遇到共享文件夹中的多平台主机和符号链接问题的人.

你如何解决这个问题,以便我们可以保持符号链接,但仍然使用不同的主机操作系统？

什么时候应该使用信号量,什么时候应该使用条件变量(CondVar)？

此代码选择同一文件夹中的所有xml文件,与调用的可执行文件一样,并且异步地将处理应用于回调方法中的每个结果(在下面的示例中,只打印出文件的名称).

如何避免使用sleep方法来保持main方法退出？我有问题缠绕我的头围绕通道(我认为这是需要的,同步结果)所以任何帮助表示赞赏!

package main

import (
    "fmt"
    "io/ioutil"
    "path"
    "path/filepath"
    "os"
    "runtime"
    "time"
)

func eachFile(extension string, callback func(file string)) {
    exeDir := filepath.Dir(os.Args[0])
    files, _ := ioutil.ReadDir(exeDir)
    for _, f := range files {
            fileName := f.Name()
            if extension == path.Ext(fileName) {
                go callback(fileName)
            }
    }
}


func main() {
    maxProcs := runtime.NumCPU()
    runtime.GOMAXPROCS(maxProcs)

    eachFile(".xml", func(fileName string) {
                // Custom logic goes in here
                fmt.Println(fileName)
            })

    // This is what i want to get rid of
    time.Sleep(100 * time.Millisecond) …

我在github上分了一个项目,做了一些改动,到目前为止一直很好.

与此同时,我分叉的存储库发生了变化,我希望将这些更改存入我的存储库.我怎么做 ？

在我的代码中,我有一个循环,等待从不同的线程更改某个状态.另一个线程工作,但我的循环永远不会看到更改的值.它永远等待.但是,当我System.out.println在循环中放置一个语句时,它突然起作用了!为什么？

以下是我的代码示例:

class MyHouse {
    boolean pizzaArrived = false;

    void eatPizza() {
        while (pizzaArrived == false) {
            //System.out.println("waiting");
        }

        System.out.println("That was delicious!");
    }

    void deliverPizza() {
        pizzaArrived = true;
    }
}

while循环正在运行时,我deliverPizza()从另一个线程调用来设置pizzaArrived变量.但循环仅在我取消注释System.out.println("waiting");语句时才有效.这是怎么回事？

我有一个ArrayList,我想用它来保存RaceCar对象,一旦完成执行就会扩展Thread类.一个名为Race的类使用RaceCar对象在完成执行时调用的回调方法处理此ArrayList.回调方法addFinisher(RaceCar finisher)将RaceCar对象添加到ArrayList.这应该给出Threads完成执行的顺序.

我知道ArrayList不是同步的,因此不是线程安全的.我尝试使用Collections.synchronizedCollection(c Collection)方法,传入一个新的ArrayList并将返回的Collection分配给ArrayList.但是,这给了我一个编译器错误:

Race.java:41: incompatible types
found   : java.util.Collection
required: java.util.ArrayList
finishingOrder = Collections.synchronizedCollection(new ArrayList(numberOfRaceCars));

这是相关代码:

public class Race implements RaceListener {
    private Thread[] racers;
    private ArrayList finishingOrder;

    //Make an ArrayList to hold RaceCar objects to determine winners
    finishingOrder = Collections.synchronizedCollection(new ArrayList(numberOfRaceCars));

    //Fill array with RaceCar objects
    for(int i=0; i<numberOfRaceCars; i++) {
    racers[i] = new RaceCar(laps, inputs[i]);

        //Add this as a RaceListener to each RaceCar
        ((RaceCar) racers[i]).addRaceListener(this);
    }

    //Implement the one method in the RaceListener interface
    public void addFinisher(RaceCar …

以下代码是否设置为正确同步呼叫synchronizedMap？

public class MyClass {
  private static Map<String, List<String>> synchronizedMap = Collections.synchronizedMap(new HashMap<String, List<String>>());

  public void doWork(String key) {
    List<String> values = null;
    while ((values = synchronizedMap.remove(key)) != null) {
      //do something with values
    }
  }

  public static void addToMap(String key, String value) {
    synchronized (synchronizedMap) {
      if (synchronizedMap.containsKey(key)) {
        synchronizedMap.get(key).add(value);
      }
      else {
        List<String> valuesList = new ArrayList<String>();
        valuesList.add(value);
        synchronizedMap.put(key, valuesList);
      }
    }
  }
}

根据我的理解,我需要同步块addToMap()来防止另一个线程调用remove()或containsKey()在我通过调用之前put()但我不需要同步块doWork()因为另一个线程无法addToMap() …

我有两个线程,一个更新一个int,另一个读取它.这是一个统计值,其中读取和写入的顺序无关紧要.

我的问题是,我是否需要同步访问这个多字节值？或者,换句话说,写入的一部分可以完成并被中断,然后读取就会发生.

例如,假设值= 0x0000FFFF,其值递增为0x00010000.

是否有时间值看起来像0x0001FFFF,我应该担心？当然,类型越大,发生这种情况的可能性就越大.

我总是同步这些类型的访问,但很好奇社区的想法.

我有一个使用git进行同步的桌面应用程序.我还有一个与桌面相同的android应用程序,但我不知道如何在其上执行同步部分.我还没有在android上找到任何git的实现.我找到了一个jgit,但它的记录不清楚,我甚至无法做到这一点.

我正在考虑从我的Android应用程序到我的git服务器的远程命令,但这对我来说真是一个挑逗.你能告诉我是否存在可以在android上使用的任何其他git实现？如果你有任何想法如何解决,请告诉我.

我有一个进程A,它在内存中包含一组带有一组记录的表(recordA,recordB等......)

现在,这个进程可以启动许多影响记录的线程,有时我们可以有2个线程试图访问同一条记录 - 这种情况必须被拒绝.特别是如果一个记录被一个线程锁定,我希望另一个线程中止(我不想BLOCK或WAIT).

目前我这样做:

synchronized(record)
{
performOperation(record);
}

但是这导致了我的问题......因为当Process1正在执行操作时,如果Process2进入,则阻塞/等待同步语句,并且当Process1完成时,它执行操作.相反,我想要这样的东西:

if (record is locked)
   return;

synchronized(record)
{
performOperation(record);
}

有关如何实现这一目标的任何线索？任何帮助将非常感激.谢谢,